apache-kafka - 高级消费者是否利用了 Kafka 0.8.2 中的新偏移管理？

Question

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

Answer 1

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

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