Versions in this module Expand all Collapse all v0 v0.1.1 Jul 22, 2022 v0.1.0 Jul 22, 2022 Changes in this version + type Consumer struct + func NewConsumer(config *sarama.Config, logger *log.Logger, topic string, groupID string, ...) *Consumer + func (c *Consumer) Consume() + func (c Consumer) Stop() + 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