features

Apr 30, 2024

Changes in this version

+ func TriggerScalesToZeroWithKeda() *feature.Feature

Apr 3, 2024

Changes in this version

+ func TriggerUsesConsumerGroupIDTemplate() *feature.Feature

Mar 26, 2024

Changes in this version

+ func SetupBrokerAuthRestrictedSslSaslScram512(ctx context.Context) *feature.Feature

Jan 24, 2024

Changes in this version

+ func KafkaSourceTLSSink() *feature.Feature

+ func KafkaSourceTLSSinkTrustBundle() *feature.Feature

+ func KnativeKafkaCEExtensionsAdded() *feature.FeatureSet

+ func SetupBrokerNoAuthSsl(ctx context.Context) *feature.Feature

Jan 22, 2024

Changes in this version

+ func KafkaSourceBinaryEventWithExtensions() *feature.Feature

Jan 15, 2024

Changes in this version

+ func KafkaSourceScalesToZeroWithKeda() *feature.Feature

Jan 8, 2024

Changes in this version

+ func RotateChannelTLSCertificates() *feature.Feature

+ func RotateSinkTLSCertificates(ctx context.Context) *feature.Feature

Dec 1, 2023

Changes in this version

+ func RotateBrokerTLSCertificates() *feature.Feature

Jul 27, 2023

Changes in this version

+ const SASLSecretName

+ const TLSSecretName

May 26, 2023

Changes in this version

+ const PlainMech

+ const SASLMech

+ const TLSMech

+ func KafkaSourceBinaryEvent() *feature.Feature

+ func KafkaSourceSASL() *feature.Feature

+ func KafkaSourceStructuredEvent() *feature.Feature

+ func KafkaSourceTLS(kafkaSource, kafkaSink, topic string) *feature.Feature

+ func KafkaSourceWithEventAfterUpdate(kafkaSource, kafkaSink, topic string) *feature.Feature

+ func KafkaSourceWithExtensions() *feature.Feature

Apr 25, 2023

Changes in this version

+ func BrokerNotReadyWithoutAuthSecret() *feature.Feature

+ func BrokerWithCustomReplicationFactorAndNumPartitions(env environment.Environment) *feature.Feature

+ func BrokerWithTriggersAndKafkaSink(env environment.Environment) *feature.Feature

+ func SetupBrokerAuth(bootstrapServer string, authSecretOptions ...manifest.CfgFn) *feature.Feature

+ func SetupBrokerAuthPlaintext() *feature.Feature

+ func SetupBrokerAuthSaslPlaintextScram512(ctx context.Context) *feature.Feature

+ func SetupBrokerAuthSsl(ctx context.Context) *feature.Feature

+ func SetupBrokerAuthSslSaslScram512(ctx context.Context) *feature.Feature

Feb 27, 2023

Changes in this version

+ func KafkaSourceInitialOffsetEarliest(count int, topic string) *feature.Feature

+ func SetupKafkaTopicWithEvents(count int, topic string) *feature.Feature

Feb 2, 2023

Changes in this version

+ func BrokerAuthSecretDoesNotExist() *feature.Feature

+ func BrokerAuthSecretForInternalTopicDoesNotExist() *feature.Feature

+ func BrokerCannotReachKafkaCluster() *feature.Feature

+ func BrokerConfigMapDeletedFirst() *feature.Feature

+ func BrokerConfigMapDoesNotExist() *feature.Feature

+ func BrokerConfigmapCreated(configName string) *feature.Feature

+ func BrokerDeletedRecreated() *feature.Feature

+ func BrokerExternalTopicAuthSecretDoesNotExist() *feature.Feature

+ func BrokerExternalTopicDoesNotExist() *feature.Feature

+ func BrokerWithBogusConfig() *feature.Feature

+ func CleanupNamespace(name string) *feature.Feature

+ func CreateSecretsAfterKafkaSource() *feature.Feature

+ func KafkaChannelLease() *feature.Feature

+ func KafkaSourceLease() *feature.Feature

+ func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature

+ func NamespacedBrokerResourcesPropagation() *feature.Feature

+ func ScaleKafkaSource() *feature.Feature

+ func SetupAndCleanupKafkaSources(prefix string, n int) *feature.Feature

+ func SetupKafkaSources(prefix string, n int) *feature.Feature

+ func SetupNamespace(name string) *feature.Feature

+ func SetupNamespacedBroker(name string) *feature.Feature

+ func TriggerLatestOffset() *feature.Feature

+ type ResourceError struct

+ Resource *contract.Resource

+ Sources *sources.KafkaSourceList

+ func (r ResourceError) Error() string