package
3.1.0+incompatible
Repository: https://github.com/terrextech/go-kafkautils.git
Documentation: pkg.go.dev
# Functions
CreateKeyMessage creates producer-formatted message with key.
CreateMessage creates keyless producer-formatted message.
NewConsumer returns a configured Sarama Consumer-Group.
NewProducer returns a configured Sarama AsyncProducer.
# Structs
Consumer wraps Sarama Consumer-Group.
ConsumerConfig wraps configuration for Sarama Consumer-Group.
Producer wraps sarama's AsyncProducer.
ProducerConfig wraps configuration for producer.