consumer

Dec 19, 2023

Changes in this version

+ const Earliest

+ type Consumer struct

+ func NewConsumer(ctx context.Context, wg *sync.WaitGroup, kafkaBootstrap string, ...) (consumer *Consumer, err error)

+ func (this *Consumer) Cleanup(sarama.ConsumerGroupSession) error

+ func (this *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (this *Consumer) Setup(sarama.ConsumerGroupSession) error