auth

Documentation

Index

• func AddFlags(configPrefix string, flagSet *flag.FlagSet)
• type AuthenticationConfig
  • func (config *AuthenticationConfig) InitFromViper(configPrefix string, v *viper.Viper)
  • func (config *AuthenticationConfig) SetConfiguration(saramaConfig *sarama.Config) error
• type KerberosConfig
• type TLSConfig

Functions

func AddFlags

func AddFlags(configPrefix string, flagSet *flag.FlagSet)

AddFlags add configuration flags to a flagSet.

Types

type AuthenticationConfig

type AuthenticationConfig struct {
	Authentication string
	Kerberos       KerberosConfig
	TLS            TLSConfig
}

AuthenticationConfig describes the configuration properties needed authenticate with kafka cluster

func (*AuthenticationConfig) InitFromViper

func (config *AuthenticationConfig) InitFromViper(configPrefix string, v *viper.Viper)

InitFromViper loads authentication configuration from viper flags.

func (*AuthenticationConfig) SetConfiguration

func (config *AuthenticationConfig) SetConfiguration(saramaConfig *sarama.Config) error

SetConfiguration set configure authentication into sarama config structure

type KerberosConfig

type KerberosConfig struct {
	ServiceName string
	Realm       string
	UseKeyTab   bool
	Username    string
	Password    string
	ConfigPath  string
	KeyTabPath  string
}

KerberosConfig describes the configuration properties needed for Kerberos authentication with kafka consumer

type TLSConfig

type TLSConfig struct {
	CertPath string
	KeyPath  string
	CaPath   string
}

TLSConfig describes the configuration properties for TLS Connections to the Kafka Brokers