为什么我无法在卡夫卡0.9.0.1中看到消费者？

Question

我有一个Kafka应用程序，可以创建多分区主题，填充它们，并从消费者那里读取它们。这似乎工作。

我想要知道卡夫卡，所以我尝试了一些工具，如卡夫卡经理和trifecta。这些工具会告诉我关于我的主题，分区等，但似乎没有看到我的消费者获得他们的抵消。

如果我看看我在kafka的主题，我会看到我的主题加上一个__consumer_offsets，我认为这意味着Kafka（而不是Zookeeper）正在存储我的消费者。

因为这是一个跨工具一致的问题，我想知道如果我没有正确设置kafka中的某些内容，或者还没有完全支持0.9.x的工具？

Answer 1

在卡夫卡0.9，你可以尝试工具kafka-consumer-groups.sh它取代了旧的命令行实用程序ConsumerOffsetChecker。这应该提供消费者的抵消信息。

在Kafka 0.9中，它具有名为__consumer_offsets的默认主题来存储偏移量而不是zookeeper。在旧版本中，您可以使用offsets.storage consumer property来控制是使用zookeeper还是kafka存储消费者偏移量，zookeeper是默认值。 kafka是首选方法，因为zookeeper没有针对并发写入进行优化。