raw

Nov 13, 2023

Changes in this version

+ type Consumer struct

+ func NewConsumer(brokers, topic []string, groupName string, instanceId string) (*Consumer, error)

+ func (c *Consumer) Close() error

+ func (c *Consumer) GetMessage() *shared.KafkaMessage

+ func (c *Consumer) GetMessages() chan *shared.KafkaMessage

+ func (c *Consumer) GetState() ConsumerState

+ func (c *Consumer) GetStats() (uint64, uint64)

+ func (c *Consumer) GetTopics() []string

+ func (c *Consumer) IsRunning() bool

+ func (c *Consumer) MarkMessage(msg *shared.KafkaMessage)

+ func (c *Consumer) MarkMessages(msgs []*shared.KafkaMessage)

+ func (c *Consumer) Start(ctx context.Context) error

+ type ConsumerState int

+ const ConsumerStateCompletingRebalance

+ const ConsumerStateDead

+ const ConsumerStateEmpty

+ const ConsumerStatePreparingRebalance

+ const ConsumerStateStable

+ const ConsumerStateUnknown

+ type GroupHandler struct

+ func (c *GroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

+ func (c *GroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (c *GroupHandler) Setup(_ sarama.ConsumerGroupSession) error

+ type TopicPartition struct

+ Partition int32

+ Topic string