interfaces

Mar 2, 2023

Changes in this version

+ type BrokerGenerator = func(addr string) SaramaBroker

Sep 13, 2022

Changes in this version

type Message

+ Context func() context.Context

+ GetHeader func(key string) string

Jan 25, 2022

Changes in this version

+ var SaramaNewAsyncProducer = sarama.NewAsyncProducer

+ var SaramaNewConsumerGroup = sarama.NewConsumerGroup

+ type ConsumerGroupInitialiser = func(addrs []string, groupID string, config *sarama.Config) (sarama.ConsumerGroup, error)

+ type Message interface

+ Commit func()

+ CommitAndRelease func()

+ GetData func() []byte

+ Mark func()

+ Offset func() int64

+ Release func()

+ UpstreamDone func() chan struct{}

+ type ProducerInitialiser = func(addrs []string, config *sarama.Config) (sarama.AsyncProducer, error)

+ type SaramaAsyncProducer = sarama.AsyncProducer

+ type SaramaBroker interface

+ Addr func() string

+ Close func() error

+ Connected func() (bool, error)

+ GetMetadata func(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)

+ Open func(conf *sarama.Config) error

+ type SaramaConsumerGroup = sarama.ConsumerGroup

+ type SaramaConsumerGroupClaim = sarama.ConsumerGroupClaim

+ type SaramaConsumerGroupSession = sarama.ConsumerGroupSession