Using the GetOffsetShell

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.

Getting ready

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.

How to do it...

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

How it works...

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 the host:port format.
• --max-wait-ms <Integer: ms>: This specifies the maximum amount...