Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2023 Changes in this version + func NewKafkaProducer(brokerList []string, config *sarama.Config) kafkaProducer + type KafkaConsumer struct + func NewKafkaConsumer(config *sarama.Config, brokerList []string, topic string, groupID string) (*KafkaConsumer, error) + func (k *KafkaConsumer) Close() + func (k *KafkaConsumer) Consume() error + func (k *KafkaConsumer) GetDataChannel() chan string