Skip to content

feat: add Kafka invocation support to func invoke#3955

Open
singhshresth26 wants to merge 1 commit into
knative:mainfrom
singhshresth26:feature/kafka-invoke
Open

feat: add Kafka invocation support to func invoke#3955
singhshresth26 wants to merge 1 commit into
knative:mainfrom
singhshresth26:feature/kafka-invoke

Conversation

@singhshresth26

Copy link
Copy Markdown

Changes

  • 🎁 Add support for invoking Kafka functions by producing a test message directly to the configured topic.
  • 🧹 Bypass local/remote HTTP route lookup when the invocation format is kafka.
  • 🧹 Add kafka as a valid option to the Invoke field jsonschema tags and regenerate the func.yaml configuration schema.
  • 🧹 Introduce a mocked kafkaWriter interface to write clean unit tests for Kafka message production without requiring a live broker.

/kind enhancement

Fixes #3931

Release Note

Added support to the CLI for invoking Kafka functions. When a function has `invoke: kafka` configured, the `func invoke` command will read `KAFKA_BROKERS` and `KAFKA_TOPICS` from `func.yaml` (interpolated) and produce a test message directly to the configured topic(s).

@knative-prow knative-prow Bot added the kind/enhancement Feature additions or improvements to existing label Jul 21, 2026
@linux-foundation-easycla

linux-foundation-easycla Bot commented Jul 21, 2026

Copy link
Copy Markdown

CLA Signed
The committers listed above are authorized under a signed CLA.

  • ✅ login: singhshresth26 / name: Shresth Singh (c1d1608)

@knative-prow
knative-prow Bot requested review from dsimansk and jrangelramos July 21, 2026 19:37
@knative-prow

knative-prow Bot commented Jul 21, 2026

Copy link
Copy Markdown

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: singhshresth26
Once this PR has been reviewed and has the lgtm label, please assign gauron99 for approval. For more information see the Code Review Process.

The full list of commands accepted by this bot can be found here.

Details Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

@knative-prow

knative-prow Bot commented Jul 21, 2026

Copy link
Copy Markdown

Welcome @singhshresth26! It looks like this is your first PR to knative/func 🎉

@knative-prow knative-prow Bot added the size/L 🤖 PR changes 100-499 lines, ignoring generated files. label Jul 21, 2026
@knative-prow

knative-prow Bot commented Jul 21, 2026

Copy link
Copy Markdown

Hi @singhshresth26. Thanks for your PR.

I'm waiting for a knative member to verify that this patch is reasonable to test. If it is, they should reply with /ok-to-test on its own line. Until that is done, I will not automatically test new commits in this PR, but the usual testing commands by org members will still work.

Regular contributors should join the org to skip this step.

Once the patch is verified, the new status will be reflected by the ok-to-test label.

I understand the commands that are listed here.

Details

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository.

@knative-prow knative-prow Bot added the needs-ok-to-test 🤖 Needs an org member to approve testing label Jul 21, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

kind/enhancement Feature additions or improvements to existing needs-ok-to-test 🤖 Needs an org member to approve testing size/L 🤖 PR changes 100-499 lines, ignoring generated files.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

func invoke support for Kafka functions

1 participant