Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + func AddFlags(configPrefix string, flagSet *flag.FlagSet) + type AuthenticationConfig struct + Authentication string + Kerberos KerberosConfig + TLS TLSConfig + func (config *AuthenticationConfig) InitFromViper(configPrefix string, v *viper.Viper) + func (config *AuthenticationConfig) SetConfiguration(saramaConfig *sarama.Config) error + type KerberosConfig struct + ConfigPath string + KeyTabPath string + Password string + Realm string + ServiceName string + UseKeyTab bool + Username string + type TLSConfig struct + CaPath string + CertPath string + KeyPath string