提问者:小点点

高级使用者是否利用了 Kafka 0.8.2 中的新偏移量管理?


在 0.8.2 中,提交偏移量似乎不再具有与以前相同的性能问题 (http://blog.confluent.io/2014/12/02/whats-coming-in-apache-kafka-0-8-2/)。高级使用者是否也利用了这一点,或者它是一个单独的 API?即,在使用高级使用者时,我可以安全地开始更频繁地提交吗?


共1个答案

匿名用户

我还不能谈论与 Zookeeper 偏移存储的性能比较,但高级消费者确实支持在 Kafka 中使用 0.8.2 存储偏移量。您可以通过将属性 offsets.storage 设置为 kafka 来配置它。您还需要在迁移过程中将属性 dual.commit.enabled 设置为 true,用于当前向 Zookeeper 提交偏移量的任何现有使用者组。

有关迁移的详细信息,请参阅 Apache Kafka 常见问题解答。