eventing-kafka

module

v0.23.1 Latest Latest Go to latest Published: May 31, 2021 License: Apache-2.0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/knative-sandbox/eventing-kafka

Links

Open Source Insights

README ¶

Kafka Eventing Components

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

# 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

Directories ¶

Path	Synopsis
cmd
channel/consolidated/controller
channel/consolidated/dispatcher
channel/distributed/controller
channel/distributed/dispatcher
channel/distributed/receiver
source/controller
source/mtcontroller
source/mtreceive_adapter
source/receive_adapter
webhook
config
channel/consolidated This package is a placeholder that allows us to pull in config files via go mod vendor.	This package is a placeholder that allows us to pull in config files via go mod vendor.
post-install Package pre_install is a placeholder that allows us to pull in config files via go mod vendor.	Package pre_install is a placeholder that allows us to pull in config files via go mod vendor.
pkg
apis/bindings Package bindings contains bindings API versions	Package bindings contains bindings API versions
apis/bindings/v1alpha1 Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
apis/bindings/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
apis/duck/v1alpha1 +k8s:deepcopy-gen=package +groupName=duck.knative.dev	+k8s:deepcopy-gen=package +groupName=duck.knative.dev
apis/kafka
apis/kafka/v1alpha1 Package v1alpha1 is the v1alpha1 version of the API.	Package v1alpha1 is the v1alpha1 version of the API.
apis/messaging
apis/messaging/v1beta1 Package v1beta1 is the v1beta1 version of the API.	Package v1beta1 is the v1beta1 version of the API.
apis/sources Package sources contains sources API versions	Package sources contains sources API versions
apis/sources/v1alpha1 Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
apis/sources/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
channel/consolidated/dispatcher
channel/consolidated/reconciler
channel/consolidated/reconciler/controller
channel/consolidated/reconciler/controller/resources
channel/consolidated/reconciler/dispatcher
channel/consolidated/reconciler/testing
channel/consolidated/status
channel/consolidated/utils
channel/distributed/common/config
channel/distributed/common/env
channel/distributed/common/health
channel/distributed/common/k8s
channel/distributed/common/kafka/admin
channel/distributed/common/kafka/admin/custom
channel/distributed/common/kafka/admin/eventhub
channel/distributed/common/kafka/admin/kafka
channel/distributed/common/kafka/admin/testing
channel/distributed/common/kafka/admin/types
channel/distributed/common/kafka/admin/util
channel/distributed/common/kafka/admin/wrapper
channel/distributed/common/kafka/constants
channel/distributed/common/kafka/consumer
channel/distributed/common/kafka/consumer/testing
channel/distributed/common/kafka/consumer/wrapper
channel/distributed/common/kafka/producer
channel/distributed/common/kafka/producer/testing
channel/distributed/common/kafka/producer/wrapper
channel/distributed/common/kafka/sarama
channel/distributed/common/kafka/testing
channel/distributed/common/kafka/util
channel/distributed/common/util
channel/distributed/controller/config
channel/distributed/controller/constants
channel/distributed/controller/env
channel/distributed/controller/event
channel/distributed/controller/kafkachannel
channel/distributed/controller/testing
channel/distributed/controller/util
channel/distributed/dispatcher/constants
channel/distributed/dispatcher/controller
channel/distributed/dispatcher/dispatcher
channel/distributed/dispatcher/env
channel/distributed/dispatcher/health
channel/distributed/dispatcher/testing
channel/distributed/receiver/channel
channel/distributed/receiver/constants
channel/distributed/receiver/env
channel/distributed/receiver/health
channel/distributed/receiver/producer
channel/distributed/receiver/testing
channel/distributed/receiver/util
channel/webhook
client/clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
client/clientset/versioned/typed/bindings/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/bindings/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/bindings/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/bindings/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/kafka/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/kafka/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/messaging/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/messaging/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/sources/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/sources/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/sources/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/sources/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/informers/externalversions
client/informers/externalversions/bindings
client/informers/externalversions/bindings/v1alpha1
client/informers/externalversions/bindings/v1beta1
client/informers/externalversions/internalinterfaces
client/informers/externalversions/kafka
client/informers/externalversions/kafka/v1alpha1
client/informers/externalversions/messaging
client/informers/externalversions/messaging/v1beta1
client/informers/externalversions/sources
client/informers/externalversions/sources/v1alpha1
client/informers/externalversions/sources/v1beta1
client/injection/client
client/injection/client/fake
client/injection/informers/bindings/v1alpha1/kafkabinding
client/injection/informers/bindings/v1alpha1/kafkabinding/fake
client/injection/informers/bindings/v1alpha1/kafkabinding/filtered
client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/fake
client/injection/informers/bindings/v1beta1/kafkabinding
client/injection/informers/bindings/v1beta1/kafkabinding/fake
client/injection/informers/bindings/v1beta1/kafkabinding/filtered
client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake
client/injection/informers/factory
client/injection/informers/factory/fake
client/injection/informers/factory/filtered
client/injection/informers/factory/filtered/fake
client/injection/informers/kafka/v1alpha1/resetoffset
client/injection/informers/kafka/v1alpha1/resetoffset/fake
client/injection/informers/kafka/v1alpha1/resetoffset/filtered
client/injection/informers/kafka/v1alpha1/resetoffset/filtered/fake
client/injection/informers/messaging/v1beta1/kafkachannel
client/injection/informers/messaging/v1beta1/kafkachannel/fake
client/injection/informers/messaging/v1beta1/kafkachannel/filtered
client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake
client/injection/informers/sources/v1alpha1/kafkasource
client/injection/informers/sources/v1alpha1/kafkasource/fake
client/injection/informers/sources/v1alpha1/kafkasource/filtered
client/injection/informers/sources/v1alpha1/kafkasource/filtered/fake
client/injection/informers/sources/v1beta1/kafkasource
client/injection/informers/sources/v1beta1/kafkasource/fake
client/injection/informers/sources/v1beta1/kafkasource/filtered
client/injection/informers/sources/v1beta1/kafkasource/filtered/fake
client/injection/reconciler/bindings/v1alpha1/kafkabinding
client/injection/reconciler/bindings/v1beta1/kafkabinding
client/injection/reconciler/kafka/v1alpha1/resetoffset
client/injection/reconciler/messaging/v1beta1/kafkachannel
client/injection/reconciler/sources/v1alpha1/kafkasource
client/injection/reconciler/sources/v1beta1/kafkasource
client/listers/bindings/v1alpha1
client/listers/bindings/v1beta1
client/listers/kafka/v1alpha1
client/listers/messaging/v1beta1
client/listers/sources/v1alpha1
client/listers/sources/v1beta1
common/client
common/client/testing
common/config
common/config/testing
common/configmaploader
common/configmaploader/fake
common/constants
common/consumer
common/metrics
common/scheduler The scheduler is responsible for placing virtual pod (VPod) replicas within real pods.	The scheduler is responsible for placing virtual pod (VPod) replicas within real pods.
common/scheduler/statefulset
common/scheduler/testing
common/testing
common/tracing
source/adapter
source/client
source/control
source/mtadapter
source/reconciler/binding
source/reconciler/mtsource Package source implements the Multi Tenant KafkaSource controller.	Package source implements the Multi Tenant KafkaSource controller.
source/reconciler/source Package source implements the KafkaSource controller.	Package source implements the KafkaSource controller.
source/reconciler/source/resources
test
e2e
e2e/helpers
lib
lib/resources
lib/setupclientoptions
rekt/features/kafkasource
rekt/features/kafkatopic
rekt/resources/kafkacat
rekt/resources/kafkasource
rekt/resources/kafkatopic
test_images/kafka-publisher
test_images/kafka_performance
upgrade
upgrade/installation

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL