Versions in this module Expand all Collapse all v1 v1.5.0 Nov 30, 2021 v1.4.6 Oct 28, 2021 Changes in this version + const MetaKafkaHeaders + const MetaKafkaKey + const MetaKafkaPartition + var ErrNoBroker = errors.New("connect kafka error, no broker here") + var SHA256 scram.HashGeneratorFcn = func() hash.Hash + var SHA512 scram.HashGeneratorFcn = func() hash.Hash + type Config struct + func NewDefultConfig() *Config + func (conf *Config) ValidatePublisherConfig() error + func (conf *Config) ValidateSubscriberConfig() error + type Publisher struct + func NewPublisher(conf *Config) (*Publisher, error) + func (b *Publisher) Connect() error + func (b *Publisher) Debug(l logger.Logger) + func (b *Publisher) Disconnect() error + func (b *Publisher) Pub(topic string, e *event.Event) error + type Subscriber struct + func NewSubscriber(conf *Config) (*Subscriber, error) + func (b *Subscriber) Debug(l logger.Logger) + func (s *Subscriber) Cleanup(sarama.ConsumerGroupSession) error + func (s *Subscriber) Connect() error + func (s *Subscriber) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (s *Subscriber) Disconnect() error + func (s *Subscriber) Setup(sarama.ConsumerGroupSession) error + func (s *Subscriber) Sub(topic string, h bus.EventHandler) error + 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)