Versions in this module Expand all Collapse all v1 v1.5.3 Aug 10, 2021 v1.5.2 Jul 22, 2021 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 + Config *sarama.Config + Consumer *TRSKafkaConsumer + ConsumerGroup *sarama.ConsumerGroup + Logger *logrus.Logger + Producer *sarama.AsyncProducer + type TRSKafkaConsumer struct + Errors chan error + Logger *logrus.Logger + Responses chan *sarama.ConsumerMessage + func (consumer *TRSKafkaConsumer) Cleanup(sarama.ConsumerGroupSession) error + func (consumer *TRSKafkaConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (consumer *TRSKafkaConsumer) Setup(sarama.ConsumerGroupSession) error Other modules containing this package github.com/Cray-HPE/hms-trs-kafkalib/v2