Versions in this module Expand all Collapse all v2 v2.0.1 Jan 7, 2022 Changes in this version + func GenerateSendReceiveConsumerGroupName(appName, workerClass, consumerGroup string) (sendTopic string, rcvTopic string, cgroupName string) + type TRSKafka struct + Client *TRSKafkaClient + ConsumerShutdown chan int + Logger *logrus.Logger + Mux sync.Mutex + RcvTopicNames []string + func (trsKafka *TRSKafka) Init(ctx context.Context, initialReceiveTopics []string, consumerGroup string, ...) (err error) + func (trsKafka *TRSKafka) SetTopics(topics []string) (err error) + func (trsKafka *TRSKafka) Shutdown() + func (trsKafka *TRSKafka) Write(topic string, payload []byte) + type TRSKafkaClient struct + Consumer *TRSKafkaConsumer + Logger *logrus.Logger + Producer *kafka.Producer + type TRSKafkaConsumer struct + Errors chan error + Logger *logrus.Logger + Responses chan *kafka.Message Other modules containing this package github.com/Cray-HPE/hms-trs-kafkalib