sarama

Documentation

Index

• func ConfigEqual(config1, config2 *sarama.Config, ignore ...interface{}) bool
• func EnableSaramaLogging(enable bool)
• func LoadEventingKafkaSettings(configMap *corev1.ConfigMap) (*commonconfig.EventingKafkaConfig, error)
• func LoadSettings(ctx context.Context) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)
• func MergeSaramaSettings(config *sarama.Config, configMap *corev1.ConfigMap) (*sarama.Config, error)
• func UpdateSaramaConfig(config *sarama.Config, clientId string, username string, password string)

Functions

func ConfigEqual

func ConfigEqual(config1, config2 *sarama.Config, ignore ...interface{}) bool

ConfigEqual is a convenience function to determine if two given sarama.Config structs are identical aside from unserializable fields (e.g. function pointers). To ignore parts of the sarama.Config struct, pass them in as the "ignore" parameter.

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) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)

Load The Sarama & EventingKafka Configuration From The ConfigMap The Provided Context Must Have A Kubernetes Client Associated With It

func MergeSaramaSettings

func MergeSaramaSettings(config *sarama.Config, configMap *corev1.ConfigMap) (*sarama.Config, error)

Extract The Sarama-Specific Settings From A ConfigMap And Merge Them With Existing Settings If config Is nil, A New sarama.Config Struct Will Be Created With Default Values

func UpdateSaramaConfig

func UpdateSaramaConfig(config *sarama.Config, clientId string, username string, password string)

Utility Function For Configuring Common Settings For Admin/Producer/Consumer