Kafka Eventing Components

These components are GA

This repository contains eventing components using Kafka as the backing implementation. It currently consists of a Source implementation, and a single KafkaChannel CRD with two backing Channel implementations (Consolidated & Distributed). The work is sponsored by the event-delivery working group.

Nightly Artifacts

Note: Replace REPLACE_WITH_CLUSTER_URL in the yaml with the URI to the Kafka Cluster (eg. my-cluster-kafka-bootstrap.kafka:9092/)

# Install the Kafka Source
kubectl apply -f https://storage.googleapis.com/knative-nightly/eventing-kafka/latest/source.yaml

# Install the Kafka "Consolidated" Channel
kubectl apply -f https://storage.googleapis.com/knative-nightly/eventing-kafka/latest/channel-consolidated.yaml

# Install the Kafka "Distributed" Channel
kubectl apply -f https://storage.googleapis.com/knative-nightly/eventing-kafka/latest/channel-distributed.yaml

---

To learn more about Knative, please visit the /docs repository.

This repo falls under the Knative Code of Conduct