查看卡夫卡分區的消息主題

Question

我有4個分區的卡夫卡主題，因爲我有4個消費者的消費者組。

我的目的是確保消息在分區間平均分配。

有沒有辦法驗證卡夫卡主題分區間的消息分佈？

Answer 1

我假設你正在使用卡夫卡新制片人。然後，您可以爲每條消息指定沒有密鑰，這意味着Kafka採用循環方式將消息平均分配到所有分區。

你可以調用以下命令將所有分區檢查分佈：

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