package
1.0.2
Repository: https://github.com/pangj520/hello.git
Documentation: pkg.go.dev

# 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