Versions in this module Expand all Collapse all v0 v0.0.0 Sep 3, 2023 Changes in this version + var GroupID string + var ProtocolVersion = sarama.V3_0_0_0 + var Topic string + func StartConsumerGroup(ctx context.Context, brokers []string) error + type Consumer struct + func (g *Consumer) Cleanup(_ sarama.ConsumerGroupSession) error + func (g *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (g *Consumer) Setup(_ sarama.ConsumerGroupSession) error
Go to main page