knative / knative/func

func invoke support for Kafka functions

Open
#3,931 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Go
Stars
365
Forks
223
Avg merge
2d 3h
Merged PRs (30d)
25

Description

`func invoke` currently only works for HTTP functions. Add support for invoking Kafka functions by producing a test message to the configured topic. The CLI should read `KAFKA_BROKERS` and `KAFKA_TOPICS` from `func.yaml` and send a message.

Blocked by knative-extensions/func-go#176 (producing support — CLI needs to produce messages to a Kafka topic).

Contributor guide

Open the contributing guide

Research direction

Start at the `func invoke` CLI entry point and the `func.yaml` configuration fields `KAFKA_BROKERS` and `KAFKA_TOPICS`. Review the blocked func-go#176 producing support, then verify that invoking a Kafka function sends a test message to the configured topic.

Written by the indexing model from the issue text.

Assessment

Tech stack
go, kafka
Domain
cli, distributed-systems
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
45/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.