kafkaclient

Jan 16, 2025

Changes in this version

+ var KafkaVersion = sarama.V3_4_0_0

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ func PrepareDefaultConfigSASL(config *sarama.Config, mechanism sarama.SASLMechanism, user string, ...)

+ func SaslMechanismFromString(saslMechanism string) (sarama.SASLMechanism, error)

+ func ValidateClientID(clientID string) error

+ type XDGSCRAMClient struct

+ func NewXDGSCRAMClient(hashGeneratorFcn scram.HashGeneratorFcn) *XDGSCRAMClient

+ func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *XDGSCRAMClient) Done() bool

+ func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)