kafka

Oct 25, 2022

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

type Message

+ Headers []sarama.RecordHeader

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

Dec 22, 2021

Changes in this version

+ func NewLeastBytesPartitioner(topic string) sarama.Partitioner

Feb 1, 2021

Changes in this version

+ func IsTopicExist(err error) bool

+ type Consumer interface

+ Close func() error

+ Commit func(context.Context, Message) error

+ Fetch func(context.Context) (Message, error)

+ GroupMode func() bool

+ func NewConsumer(cc conf.ConnectorConfig, dialTimeout time.Duration) (Consumer, error)

+ type Manager interface

+ Close func() error

+ CreateTopic func(topic string, partitions, replication int) error

+ func NewManager(cc conf.ConnectorConfig, bc conf.NATSKafkaBridgeConfig) (Manager, error)

+ type Message struct

+ Key []byte

+ Offset int64

+ Partition int

+ Topic string

+ Value []byte

+ type Producer interface

+ Close func() error

+ Write func(Message) error

+ func NewErroredProducer(err error) Producer

+ func NewProducer(cc conf.ConnectorConfig, bc conf.NATSKafkaBridgeConfig, topic string) (Producer, error)