【发布时间】:2016-08-28 15:36:38
【问题描述】:
在选择 auto.commit.interval.ms 的值时有什么最佳做法吗?
我读到here:
一般来说,不建议将此间隔保持得太小,因为它会极大地增加 zookeeper 中的读/写速率,而 zookeeper 会变慢,因为它在其仲裁中具有很强的一致性。
什么太小了?这仍然是 kafka >= 0.9.0 版本的问题吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
在选择 auto.commit.interval.ms 的值时有什么最佳做法吗?
我读到here:
一般来说,不建议将此间隔保持得太小,因为它会极大地增加 zookeeper 中的读/写速率,而 zookeeper 会变慢,因为它在其仲裁中具有很强的一致性。
什么太小了?这仍然是 kafka >= 0.9.0 版本的问题吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
问题不是什么是小,而是你能忍受什么?如果您可以在消费者崩溃的情况下重新处理几分钟的消息,您可以将间隔设置为几分钟。因为这就是它的全部内容:消息将在从最后提交的偏移量(重新)开始后处理。
【讨论】: