跨 Kafka 主题分区查看消息

【问题标题】：View messages across partitions of Kafka topic跨 Kafka 主题分区查看消息
【发布时间】：2017-04-29 09:23:29
【问题描述】：

我有一个有 4 个分区的 kafka 主题，因为我有一个有 4 个消费者的消费者组。

我的目的是确保消息在分区之间均匀分布。

有没有办法验证跨 kafka 主题分区的消息分布？

【问题讨论】：

【解决方案1】：

我假设您正在使用 Kafka 新生产者。然后你可以不为每条消息指定 key，这意味着 Kafka 采用循环方式将消息平均分配到所有分区。

您可以调用以下命令来检查所有分区的分布：

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list broker1:9092 --topic <topic> --time -1

【讨论】：