在 0.8.2 中,提交偏移量似乎不再具有与以前相同的性能问题 (http://blog.confluent.io/2014/12/02/whats-coming-in-apache-kafka-0-8-2/)。高级使用者是否也利用了这一点,或者它是一个单独的 API?即,在使用高级使用者时,我可以安全地开始更频繁地提交吗?
我还不能谈论与 Zookeeper 偏移存储的性能比较,但高级消费者确实支持在 Kafka 中使用 0.8.2 存储偏移量。您可以通过将属性 offsets.storage
设置为 kafka
来配置它。您还需要在迁移过程中将属性 dual.commit.enabled
设置为 true
,用于当前向 Zookeeper 提交偏移量的任何现有使用者组。
有关迁移的详细信息,请参阅 Apache Kafka 常见问题解答。