Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnableSaramaLogging ¶
func EnableSaramaLogging(enable bool)
Utility Function For Enabling Sarama Logging (Debugging)
func LoadEventingKafkaSettings ¶
func LoadEventingKafkaSettings(configMap *corev1.ConfigMap) (*commonconfig.EventingKafkaConfig, error)
func LoadSettings ¶
func LoadSettings(ctx context.Context, clientId string, kafkaAuthConfig *client.KafkaAuthConfig) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)
Load The Sarama & EventingKafka Configuration From The ConfigMap The Provided Context Must Have A Kubernetes Client Associated With It
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.