kafka

Mar 18, 2022

Changes in this version

+ func AsyncConsumeMessages(consumer async.Consumer, expectedMessageCount int) ([]string, error)

+ func CreateProducerMessage(topic, message string) *sarama.ProducerMessage

+ func CreateTopics(broker string, topics ...string) error

+ func NewProducer(broker string) (sarama.SyncProducer, error)

+ func SendMessages(broker string, messages ...*sarama.ProducerMessage) error