java - Kafka控制台消费者获取分区

Question

我正在使用 Kafka 控制台消费者来消费来自具有多个分区的主题的消息:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic events

但它只打印消息正文。有没有办法打印记录元数据或分区号？因为我想知道消息来自何处。

我探索了控制台消费者文档 http://documentation.kamanja.org/_static/command-ref/kafka-console-consumer.pdf但没有找到任何相关属性。

更新:

因此，正如我所见，唯一的解决方案是覆盖 DefaultMessageFormatter.class(我们可以通过使用 --formatter 属性运行 kafka 控制台消费者来设置它)并添加自定义在#writeTo(..) 方法中打印记录元数据的逻辑。

Answer 1

考虑使用更强大的 Kafka 命令行消费者，如 kafkacat https://github.com/edenhill/kafkacat/blob/master/README.md

例如，以下命令将打印每条消费消息的主题、分区、偏移量和消息负载/值:

kafkacat -b <broker> -C -t <topic> -f '%t %p @ %o: %s\n'