testing

Feb 23, 2021

Changes in this version

+ const DefaultKafkaBroker

+ const DefaultSecretNamespace

+ const DefaultSecretPassword

+ const DefaultSecretSaslType

+ const DefaultSecretUsername

+ func NewKafkaSecret(options ...KafkaSecretOption) *corev1.Secret

+ func WithEmptyUsername(secret *corev1.Secret)

+ func WithMissingConfig(secret *corev1.Secret)

+ func WithModifiedNamespace(secret *corev1.Secret)

+ func WithModifiedPassword(secret *corev1.Secret)

+ func WithModifiedSaslType(secret *corev1.Secret)

+ func WithModifiedUsername(secret *corev1.Secret)

+ type KafkaSecretOption func(secret *corev1.Secret)

Jan 13, 2021

Changes in this version

+ const DefaultEventingKafkaConfigYaml

+ const DefaultSaramaConfigYaml

+ func NewKafkaConfigMap(options ...KafkaConfigMapOption) *corev1.ConfigMap

+ func WithModifiedSaramaAdmin(configMap *corev1.ConfigMap)

+ func WithModifiedSaramaConsumer(configMap *corev1.ConfigMap)

+ func WithModifiedSaramaMetadata(configMap *corev1.ConfigMap)

+ func WithModifiedSaramaNet(configMap *corev1.ConfigMap)

+ func WithModifiedSaramaProducer(configMap *corev1.ConfigMap)

+ func WithoutEventingKafkaConfiguration(configMap *corev1.ConfigMap)

+ type KafkaConfigMapOption func(configMap *corev1.ConfigMap)