Как получить максимальное смещение Kafka от производителя

Question

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

Answer 1

Kafka предоставляет системный инструмент GetOffsetShell, чтобы получить последнее смещение каждого раздела темы.
Например, рассмотрим тему «MyTestTopic» с 2 разделами. Тогда команда должна быть как

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --partitions 1,0 --topic MyTestTopic --time -1