kafka

Dec 17, 2022

Changes in this version

+ func CreateMessage(data []byte, topic string) *kafka.Message

+ func GetReader() *kafka.Consumer

+ func InitializeAndRunLoop()

+ type Producer interface

+ Produce func(msg *kafka.Message, deliveryChan chan kafka.Event) error

+ func CreateProducer() (Producer, error)