查看跨 Kafka 主题分区的消息

Question

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

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

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

Answer 1

我假设您正在使用 Kafka 新制作人。然后您可以不为每条消息指定任何键，这意味着 Kafka 采用循环方式将消息均匀地分发到所有分区。

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

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