sarama

Documentation

Index

• func AuthFromSarama(config *sarama.Config) *client.KafkaAuthConfig
• func EnableSaramaLogging(enable bool)
• func LoadEventingKafkaSettings(configMap *corev1.ConfigMap) (*commonconfig.EventingKafkaConfig, error)
• func LoadSettings(ctx context.Context, clientId string, kafkaAuthConfig *client.KafkaAuthConfig) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)

Functions

func AuthFromSarama

func AuthFromSarama(config *sarama.Config) *client.KafkaAuthConfig

AuthFromSarama creates a KafkaAuthConfig using the SASL settings from a given Sarama config, or nil if there is no SASL user in that config

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