kafka

Oct 8, 2022

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ type KafkaSASLAlgorithm string

+ const KAFKA_SASL_NONE

+ const KAFKA_SASL_PLAIN

+ const KAFKA_SASL_SCRAM_SHA256

+ const KAFKA_SASL_SCRAM_SHA512

+ type XDGSCRAMClient struct

+ 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)

Mar 14, 2022

Changes in this version

+ type KafkaDriver struct

+ func (d *KafkaDriver) Close(context.Context) error

+ func (d *KafkaDriver) Init(context.Context) error

+ func (d *KafkaDriver) Prepare() error

+ func (d *KafkaDriver) Send(key, data []byte) error