Eri*_*son 2 apache-kafka kafka-consumer-api
选择auto.commit.interval.ms的值时,是否有最佳实践?
我在这里读到:
通常,不建议将此间隔设置得太小,因为它会极大地增加Zookeeper的读/写速率,并且由于其在整个仲裁群体中的一致性非常强,因此使其速度变慢。
什么太小?kafka> = 0.9.0版本仍然存在问题吗?
问题不是什么很小,而是你能忍受什么?如果您可以在消费者崩溃的情况下重新处理几分钟的消息,则可以将间隔设置为几分钟。因为这就是全部内容:从最后提交的偏移量(重新)开始后,将处理消息。