eventing-kafka-broker

module

v0.41.1 Latest Latest Go to latest Published: May 3, 2024 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-broker

Links

Open Source Insights

README ¶

Knative + Apache Kafka

These components are GA

If you’re using Knative or if you like the project, please ★ this repository to show your support! 🤩

Eventing Kafka Broker Docs • Eventing Kafka Sink Docs • Eventing Kafka Channel Docs • Contributing • Help Wanted Issues • Open Knative Issues to Work On

Working Group

Sponsoring WG
Eventing

Directories ¶

Path	Synopsis
control-plane
cmd/kafka-controller
cmd/kafka-source-controller
cmd/post-install
cmd/webhook-kafka
pkg/apis/bindings Package bindings contains bindings API versions	Package bindings contains bindings API versions
pkg/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
pkg/apis/config
pkg/apis/core
pkg/apis/eventing
pkg/apis/eventing/v1
pkg/apis/eventing/v1alpha1 +k8s:deepcopy-gen=package +groupName=eventing.knative.dev	+k8s:deepcopy-gen=package +groupName=eventing.knative.dev
pkg/apis/internals/kafka/eventing
pkg/apis/internals/kafka/eventing/v1alpha1 +k8s:deepcopy-gen=package +groupName=internal.kafka.eventing.knative.dev	+k8s:deepcopy-gen=package +groupName=internal.kafka.eventing.knative.dev
pkg/apis/messaging
pkg/apis/messaging/v1beta1 Package v1beta1 is the v1beta1 version of the API.	Package v1beta1 is the v1beta1 version of the API.
pkg/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.
pkg/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
pkg/autoscaler
pkg/autoscaler/keda
pkg/client/clientset/versioned
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/bindings/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/bindings/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/eventing/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/eventing/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/messaging/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/messaging/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/sources/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/sources/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/bindings
pkg/client/informers/externalversions/bindings/v1beta1
pkg/client/informers/externalversions/eventing
pkg/client/informers/externalversions/eventing/v1alpha1
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/messaging
pkg/client/informers/externalversions/messaging/v1beta1
pkg/client/informers/externalversions/sources
pkg/client/informers/externalversions/sources/v1beta1
pkg/client/injection/client
pkg/client/injection/client/fake
pkg/client/injection/informers/bindings/v1beta1/kafkabinding
pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake
pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered
pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake
pkg/client/injection/informers/eventing/v1alpha1/kafkasink
pkg/client/injection/informers/eventing/v1alpha1/kafkasink/fake
pkg/client/injection/informers/eventing/v1alpha1/kafkasink/filtered
pkg/client/injection/informers/eventing/v1alpha1/kafkasink/filtered/fake
pkg/client/injection/informers/factory
pkg/client/injection/informers/factory/fake
pkg/client/injection/informers/factory/filtered
pkg/client/injection/informers/factory/filtered/fake
pkg/client/injection/informers/messaging/v1beta1/kafkachannel
pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake
pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered
pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake
pkg/client/injection/informers/sources/v1beta1/kafkasource
pkg/client/injection/informers/sources/v1beta1/kafkasource/fake
pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered
pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/fake
pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding
pkg/client/injection/reconciler/eventing/v1alpha1/kafkasink
pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel
pkg/client/injection/reconciler/sources/v1beta1/kafkasource
pkg/client/internals/kafka/clientset/versioned
pkg/client/internals/kafka/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/internals/kafka/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/internals/kafka/clientset/versioned/typed/eventing/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/internals/kafka/clientset/versioned/typed/eventing/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/internals/kafka/informers/externalversions
pkg/client/internals/kafka/informers/externalversions/eventing
pkg/client/internals/kafka/informers/externalversions/eventing/v1alpha1
pkg/client/internals/kafka/informers/externalversions/internalinterfaces
pkg/client/internals/kafka/injection/client
pkg/client/internals/kafka/injection/client/fake
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumer
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumer/fake
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumer/filtered
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumer/filtered/fake
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumergroup
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumergroup/fake
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumergroup/filtered
pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumergroup/filtered/fake
pkg/client/internals/kafka/injection/informers/factory
pkg/client/internals/kafka/injection/informers/factory/fake
pkg/client/internals/kafka/injection/informers/factory/filtered
pkg/client/internals/kafka/injection/informers/factory/filtered/fake
pkg/client/internals/kafka/injection/reconciler/eventing/v1alpha1/consumer
pkg/client/internals/kafka/injection/reconciler/eventing/v1alpha1/consumergroup
pkg/client/internals/kafka/listers/eventing/v1alpha1
pkg/client/listers/bindings/v1beta1
pkg/client/listers/eventing/v1alpha1
pkg/client/listers/messaging/v1beta1
pkg/client/listers/sources/v1beta1
pkg/config
pkg/contract
pkg/core/config
pkg/counter
pkg/kafka
pkg/kafka/clientpool
pkg/kafka/offset
pkg/kafka/sarama
pkg/kafka/testing
pkg/logging
pkg/prober
pkg/prober/probertesting
pkg/propagator
pkg/receiver
pkg/reconciler/base receiver_condition_set.go contains Broker and Kafka Sink logic for status conditions handling.	receiver_condition_set.go contains Broker and Kafka Sink logic for status conditions handling.
pkg/reconciler/broker
pkg/reconciler/channel
pkg/reconciler/channel/apis/messaging
pkg/reconciler/channel/resources
pkg/reconciler/channel/v2
pkg/reconciler/consumer
pkg/reconciler/consumergroup
pkg/reconciler/sink
pkg/reconciler/source
pkg/reconciler/testing
pkg/reconciler/trigger
pkg/reconciler/trigger/v2
pkg/security
pkg/util
test
cmd/logs-exporter
cmd/watch-cm
e2e_new
e2e_new/bogus_config
e2e_new/multiple_partition_config
e2e_new/single_partition_config
e2e_sink
e2e_source/helpers
experimental/features_config
lib
lib/resources
pkg
pkg/addressable
pkg/broker
pkg/kafka
pkg/logging
pkg/observability
pkg/sink
pkg/testing
pkg/tracing
rekt/features
rekt/features/featuressteps
rekt/features/kafkachannel
rekt/features/kafkafeatureflags
rekt/resources/configmap
rekt/resources/configmap/broker
rekt/resources/kafkaauthsecret
rekt/resources/kafkachannel
rekt/resources/kafkasink
rekt/resources/kafkasource
rekt/resources/kafkatopic
test_images/committed-offset
test_images/consumer-group-lag-provider-test
test_images/kafka-consumer
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.
pkg/apis/keda/v1alpha1 Package v1alpha1 contains API Schema definitions for the keda v1alpha1 API group +kubebuilder:object:generate=true +groupName=keda.sh	Package v1alpha1 contains API Schema definitions for the keda v1alpha1 API group +kubebuilder:object:generate=true +groupName=keda.sh
pkg/client/clientset/versioned
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/keda/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/keda/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/keda
pkg/client/informers/externalversions/keda/v1alpha1
pkg/client/injection/client
pkg/client/injection/client/fake
pkg/client/injection/informers/factory
pkg/client/injection/informers/factory/fake
pkg/client/injection/informers/factory/filtered
pkg/client/injection/informers/factory/filtered/fake
pkg/client/injection/informers/keda/v1alpha1/clustertriggerauthentication
pkg/client/injection/informers/keda/v1alpha1/clustertriggerauthentication/fake
pkg/client/injection/informers/keda/v1alpha1/clustertriggerauthentication/filtered
pkg/client/injection/informers/keda/v1alpha1/clustertriggerauthentication/filtered/fake
pkg/client/injection/informers/keda/v1alpha1/scaledjob
pkg/client/injection/informers/keda/v1alpha1/scaledjob/fake
pkg/client/injection/informers/keda/v1alpha1/scaledjob/filtered
pkg/client/injection/informers/keda/v1alpha1/scaledjob/filtered/fake
pkg/client/injection/informers/keda/v1alpha1/scaledobject
pkg/client/injection/informers/keda/v1alpha1/scaledobject/fake
pkg/client/injection/informers/keda/v1alpha1/scaledobject/filtered
pkg/client/injection/informers/keda/v1alpha1/scaledobject/filtered/fake
pkg/client/injection/informers/keda/v1alpha1/triggerauthentication
pkg/client/injection/informers/keda/v1alpha1/triggerauthentication/fake
pkg/client/injection/informers/keda/v1alpha1/triggerauthentication/filtered
pkg/client/injection/informers/keda/v1alpha1/triggerauthentication/filtered/fake
pkg/client/listers/keda/v1alpha1

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