eventing-kafka

module

v0.39.0 Latest Latest Go to latest Published: Oct 25, 2023 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-extensions/eventing-kafka

Links

Open Source Insights

README ¶

Kafka Eventing Components

These components are GA

This repository contains a multitenant Kafka Source.

Kafka Channel

The Golang-based Kafka channel was deprecated and replaced by the KafkaChannel, maintained here.

Nightly Artifacts

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

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

This repo falls under the Knative Code of Conduct

Directories ¶

Path	Synopsis
cmd
source/mtcontroller
source/mtreceive_adapter
config
source/post-install Package post_install is a placeholder that allows us to pull in config files via go mod vendor.	Package post_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/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=bindings.knative.dev
apis/sources Package sources contains sources API versions	Package sources contains sources API versions
apis/sources/config Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.	Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.
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
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/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/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/v1beta1
client/informers/externalversions/internalinterfaces
client/informers/externalversions/sources
client/informers/externalversions/sources/v1beta1
client/injection/client
client/injection/client/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/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/v1beta1/kafkabinding
client/injection/reconciler/sources/v1beta1/kafkasource
client/listers/bindings/v1beta1
client/listers/sources/v1beta1
common/client
common/client/testing
common/commands/resetoffset/controller/testing
common/config
common/config/testing
common/configmaploader
common/configmaploader/fake
common/constants
common/consumer
common/kafka/offset
common/kafka/sarama
common/kafka/testing
common/metrics
common/testing
common/tracing
source/adapter
source/client
source/mtadapter
source/reconciler/binding
source/reconciler/common
source/reconciler/mtsource Package source implements the Multi Tenant KafkaSource controller.	Package source implements the Multi Tenant KafkaSource controller.
test
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
test_images/wathola-kafka-sender
upgrade
upgrade/continual
upgrade/installation
third_party
VENDOR-LICENSE/github.com/hashicorp/errwrap Package errwrap implements methods to formalize error wrapping in Go.	Package errwrap implements methods to formalize error wrapping in Go.
VENDOR-LICENSE/github.com/hashicorp/go-cleanhttp Package cleanhttp offers convenience utilities for acquiring "clean" http.Transport and http.Client structs.	Package cleanhttp offers convenience utilities for acquiring "clean" http.Transport and http.Client structs.
VENDOR-LICENSE/github.com/hashicorp/go-multierror
VENDOR-LICENSE/github.com/hashicorp/go-retryablehttp Package retryablehttp provides a familiar HTTP client interface with automatic retries and exponential backoff.	Package retryablehttp provides a familiar HTTP client interface with automatic retries and exponential backoff.
VENDOR-LICENSE/github.com/hashicorp/go-uuid
VENDOR-LICENSE/github.com/hashicorp/golang-lru Package lru provides three different LRU caches of varying sophistication.	Package lru provides three different LRU caches of varying sophistication.
VENDOR-LICENSE/github.com/hashicorp/golang-lru/simplelru Package simplelru provides simple LRU implementation based on build-in container/list.	Package simplelru provides simple LRU implementation based on build-in container/list.

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