Versions in this module Expand all Collapse all v0 v0.0.6 Sep 23, 2021 v0.0.5 Sep 22, 2021 Changes in this version + var SHA256 scram.HashGeneratorFcn = sha256.New + var SHA512 scram.HashGeneratorFcn = sha512.New + func InitConsumer(cfg *Config, dataChan chan *ConsumerData, f ...FuncCfg) + type Config struct + Brokers string + Ca string + Group string + Protocol string + Pwd string + Topic string + User string + Version string + type Consumer struct + func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error + func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error + type ConsumerData struct + Msg []byte + Offset int64 + Partition int32 + Topic string + type Engine struct + func InitProducer(cfg *Config, f ...FuncCfg) *Engine + func (e *Engine) SendMsg(topic, message string, partition int32) (err error) + func (e *Engine) SendMsgs(msgs []*sarama.ProducerMessage) (err error) + type FuncCfg func(e *Engine) error + func SetClientId(v string) FuncCfg + func SetOffsetsInitial(v int64) FuncCfg + func SetPartitioner(v sarama.PartitionerConstructor) FuncCfg + func SetReBalanceStrategy(v sarama.BalanceStrategy) FuncCfg + func SetRequiredAcks(v sarama.RequiredAcks) FuncCfg + 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)
Go to main page