Просмотр сообщений через разделы Kafka

Question

У меня есть тема kafka с 4 разделами, так как у меня есть группа потребителей с 4 потребителями.

Я намерен обеспечить равномерное распределение сообщений по разделам.

Есть ли способ проверить распределение сообщений между разделами темы kafka?

Answer 1

Я предполагаю, что вы используете нового производителя Kafka. Тогда вы не можете указать ни одного ключа для каждого сообщения, а это значит, что Kafka использует циклический способ равномерного распространения сообщений на все разделы.

Вы можете вызвать команду ниже, чтобы проверить распределение по всем разделам:

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