Skip to content

func cluster create: optional --kafka to install a Kafka broker #4061

Description

@gauron99

Problem

Kafka functions (run.kafka) and KEDA consumer-lag scaling (#4051) have no automated tests against a real broker. func cluster create / hack/cluster.sh install no Kafka, so #3956 can't run in CI, and manual testing needs hand-written manifests.

Proposal

Add --kafka ($FUNC_CLUSTER_KAFKA, default off) next to --serving, --eventing, --keda and --tekton:

  • install a single-node Kafka broker in a kafka namespace, reachable at kafka.kafka.svc.cluster.local:9092
  • pin its version in hack/component-versions.json
  • optionally a SASL_PLAINTEXT listener with a fixed test user, to test credentials (TriggerAuthentication)

Open questions

Related: #3956, #4051

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions