Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AuthenticationConfig ¶
type AuthenticationConfig struct {
Authentication string
Kerberos KerberosConfig
TLS configtls.ClientConfig
PlainText PlainTextConfig
}
AuthenticationConfig describes the configuration properties needed authenticate with kafka cluster
func (*AuthenticationConfig) InitFromViper ¶
func (config *AuthenticationConfig) InitFromViper(configPrefix string, v *viper.Viper) error
InitFromViper loads authentication configuration from viper flags.
func (*AuthenticationConfig) SetConfiguration ¶
func (config *AuthenticationConfig) SetConfiguration(saramaConfig *sarama.Config, logger *zap.Logger) error
SetConfiguration set configure authentication into sarama config structure
type KerberosConfig ¶
type KerberosConfig struct {
ServiceName string `mapstructure:"service_name"`
Realm string `mapstructure:"realm"`
UseKeyTab bool `mapstructure:"use_keytab"`
Username string `mapstructure:"username"`
Password string `mapstructure:"password" json:"-"`
ConfigPath string `mapstructure:"config_file"`
KeyTabPath string `mapstructure:"keytab_file"`
DisablePAFXFast bool `mapstructure:"disable_pa_fx_fast"`
}
KerberosConfig describes the configuration properties needed for Kerberos authentication with kafka consumer
type PlainTextConfig ¶ added in v1.17.0
type PlainTextConfig struct {
Username string `mapstructure:"username"`
Password string `mapstructure:"password" json:"-"`
Mechanism string `mapstructure:"mechanism"`
}
PlainTextConfig describes the configuration properties needed for SASL/PLAIN with kafka
Source Files
Click to show internal directories.
Click to hide internal directories.