Versions in this module Expand all Collapse all v0 v0.14.0 May 8, 2020 Changes in this version + 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
Go to main page