sarama

Documentation

Index

• Constants
• func AuthFromSarama(config *sarama.Config) *client.KafkaAuthConfig
• func EnableSaramaLogging(enable bool)
• func LoadEventingKafkaSettings(configMap map[string]string) (*commonconfig.EventingKafkaConfig, error)
• func LoadSettings(ctx context.Context, clientId string, configMap map[string]string, ...) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)
• func StringifyHeaderPtrs(headers []*sarama.RecordHeader) map[string][]string
• func StringifyHeaders(headers []sarama.RecordHeader) map[string][]string

Constants

const DefaultAuthSecretName = "kafka-cluster"

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)

EnableSaramaLogging Is A Utility Function For Enabling Sarama Logging (Debugging)

func LoadEventingKafkaSettings

func LoadEventingKafkaSettings(configMap map[string]string) (*commonconfig.EventingKafkaConfig, error)

func LoadSettings

func LoadSettings(ctx context.Context, clientId string, configMap map[string]string, kafkaAuthConfig *client.KafkaAuthConfig) (*sarama.Config, *commonconfig.EventingKafkaConfig, error)

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

func StringifyHeaderPtrs

func StringifyHeaderPtrs(headers []*sarama.RecordHeader) map[string][]string

StringifyHeaderPtrs Is A Pointer-version of the StringifyHeaders function

func StringifyHeaders

func StringifyHeaders(headers []sarama.RecordHeader) map[string][]string

StringifyHeaders Is A Utility function to convert []byte headers to string ones for logging purposes