util

Documentation

Index

• func AddDebugFlags(configMap *kafka.ConfigMap, flags string)
• func AddSaslAuthentication(configMap *kafka.ConfigMap, mechanism string, username string, password string)
• func AppendKafkaChannelServiceNameSuffix(channelName string) string
• func TopicName(namespace string, name string) string
• func TrimKafkaChannelServiceNameSuffix(serviceName string) string

Functions

func AddDebugFlags

func AddDebugFlags(configMap *kafka.ConfigMap, flags string)

Utility Function For Adding Debug Flags To Kafka ConfigMap

Note - Flags is a CSV string of all the appropriate kafka/librdkafka debug settings.

Valid values as of this writing include...
    generic, broker, topic, metadata, feature, queue, msg, protocol, cgrp,
    security, fetch, interceptor, plugin, consumer, admin, eos, all

Example - Common Producer values might be "broker,topic,msg,protocol,security"

func AddSaslAuthentication

func AddSaslAuthentication(configMap *kafka.ConfigMap, mechanism string, username string, password string)

Utility Function For Adding Authentication Credentials To Kafka ConfigMap

func AppendKafkaChannelServiceNameSuffix

func AppendKafkaChannelServiceNameSuffix(channelName string) string

Append The KafkaChannel Service Name Suffix To The Specified String (To Workaround Kyma Naming Conflict)

func TopicName

func TopicName(namespace string, name string) string

Get The Formatted Kafka Topic Name From The Specified Components

func TrimKafkaChannelServiceNameSuffix

func TrimKafkaChannelServiceNameSuffix(serviceName string) string

Remove The KafkaChannel Service Name Suffix From The Specified String (To Workaround Kyma Naming Conflict)