search

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
MIT License
1.01k stars 222 forks source link

修改consumer提交的时间间隔 #308

Open CHneger opened 4 years ago

CHneger commented 4 years ago

适配新版本的sarama，新版本的consumer配置增加了AutoCommit 将CommitInterval配置放入其中