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.
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