When debugging an Apache Kafka project, it is sometimes useful to obtain the offset values of the topics. For this purpose, this tool comes in handy.
For this recipe, Kafka must be installed, ZooKeeper running, broker running, and some topics created on it. The topics should have produced some messages and have some consumers created.
From the Kafka installation directory, run the following command:
$ bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic source-topic --time -1
The output is something like the following:
source-topic:0:0source-topic:1:0source-topic:2:6source-topic:3:0
The GetOffsetShell
is an interactive shell to get the consumer offsets and takes the following options:
--broker-list <String: hostname:port>
: This specifies the list of server ports to connect to in a comma-separated list in thehost:port
format.--max-wait-ms <Integer: ms>
: This specifies the maximum amount...