consumer

Oct 5, 2022

retracted

Changes in this version

+ const BATCH_MAX_BYTES

+ const BATCH_MIN_BYTES

+ type Consumer struct

+ Group string

+ KafkaAddr string

+ Partition int

+ Topic string

+ func InitConsumer(addr, topic, group string, partition int) *Consumer

+ func (c *Consumer) ConsumeEvent(messageChan chan kafka.Message)

+ func (c *Consumer) Stop()