redpanda_old

Dec 6, 2023

Changes in this version

+ type Consumer struct

+ func NewConsumer(kafkaBrokers, httpBrokers, subscribeRegexes []string, ...) (*Consumer, error)

+ func (c *Consumer) Close() error

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

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

+ func (c *Consumer) GetStats() 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() error

+ type GroupHandler struct

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

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

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

+ type TopicPartition struct

+ Partition int32

+ Topic string