# Functions
创建异步生产者,不建议每生产一条消息创建一个AsyncProducer.
创建消费组客户端当producer产生的消息指定key,则只有一个消费组客户端能消费到消息,不指定则都能消费到;并发消费同一个group需创建多个消费组客户端.
*
创建kafka默认配置
args[0]: kafka brokers, []string
args[1]: kafka version, string
*/.
创建同步生产者,不建议每生产一条消息创建一个SyncProducer.
默认的sarama配置.
# Structs
No description provided by the author
Consumer represents a Sarama consumer group consumer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author