/eventing-kafka

Kafka integrations with Knative Eventing.

Primary LanguageGoApache License 2.0Apache-2.0

Kafka Eventing Components

go.dev reference Go Report Card Releases LICENSE codecov TestGrid Slack Slack

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

Nightly Artifacts

# 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