Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = sha256.New
View Source
var SHA512 scram.HashGeneratorFcn = sha512.New
Functions ¶
func SASLVersion ¶
func SASLVersion(kafkaVersion sarama.KafkaVersion, saslVersion *int) (int16, error)
Types ¶
type Config ¶
type Config struct { tls.ClientConfig Version string `toml:"version"` ClientID string `toml:"client_id"` SASLAuth CompressionCodec int `toml:"compression_codec"` }
Config common to all Kafka clients.
type ReadConfig ¶
type ReadConfig struct {
Config
}
ReadConfig for kafka clients meaning to read from Kafka.
type SASLAuth ¶
type SASLAuth struct { SASLVersion *int `toml:"sasl_version"` SASLUsername string `toml:"sasl_username"` SASLPassword string `toml:"sasl_password"` SASLMechanism string `toml:"sasl_mechanism"` SASLGSSAPIServiceName string `toml:"sasl_gssapi_service_name"` // GSSAPI config SASLGSSAPIAuthType string `toml:"sasl_gssapi_auth_type"` // GSSAPI config SASLGSSAPIKerberosConfigPath string `toml:"sasl_gssapi_kerberos_config_path"` // GSSAPI config SASLGSSAPIKeyTabPath string `toml:"sasl_gssapi_key_tab_path"` // GSSAPI config SASLGSSAPIRealm string `toml:"sasl_gssapi_realm"` // GSSAPI config SASLAccessToken string `toml:"sasl_access_token"` // OAUTHBEARER config. experimental. undoubtedly this is not good enough. SASLGSSAPIDisablePAFXFAST bool `toml:"sasl_gssapi_disable_pafxfast"` // GSSAPI config }
func (*SASLAuth) SetSASLConfig ¶
SetSASLConfig configures SASL for kafka (sarama)
type WriteConfig ¶
type WriteConfig struct { Config RequiredAcks int `toml:"required_acks"` MaxRetry int `toml:"max_retry"` MaxMessageBytes int `toml:"max_message_bytes"` IdempotentWrites bool `toml:"idempotent_writes"` }
WriteConfig for kafka clients meaning to write to kafka
type XDGSCRAMClient ¶
type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn }
func (*XDGSCRAMClient) Begin ¶
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶
func (x *XDGSCRAMClient) Done() bool
Click to show internal directories.
Click to hide internal directories.