Versions in this module Expand all Collapse all v0 v0.1.0 Nov 22, 2021 Changes in this version + type Consumer struct + func NewConsumer(config *sarama.Config, logger *log.Logger, topic string, groupID string, ...) *Consumer + func (c Consumer) CloseConnection() + func (c Consumer) Consume() + type ConsumerGroupHandler struct + func (ConsumerGroupHandler) Cleanup(_ sarama.ConsumerGroupSession) error + func (ConsumerGroupHandler) Setup(_ sarama.ConsumerGroupSession) error + func (h ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + type Producer struct + func NewProducer(config *sarama.Config, logger *log.Logger, topic string, brokers []string) *Producer + func (p *Producer) Publish(message string)
Go to main page