Versions in this module Expand all Collapse all v1 v1.0.1 Aug 11, 2020 Changes in this version + func Consume() + func Consume2() + func Produce(msg []byte) error + type Consumer struct + func (consumer *Consumer) Cleanup(session sarama.ConsumerGroupSession) error + func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (consumer *Consumer) Setup(session sarama.ConsumerGroupSession) error v1.0.0 Aug 7, 2019 Changes in this version + type ProducerPool struct + InputQueue chan []byte + ProducerNum int + func (pp *ProducerPool) Run()