Monthly Archives: January 2022

Some useful Kafka command

Get the max partition:offset for a topic

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list broker-ip:port --topic topic-name

Get current partition:offset for a consumer group

./kafka-consumer-groups.sh --bootstrap-server broker-ip:port --group consumer-group-name --describe

Get a single record by partition:offset

./kafka-console-consumer.sh --bootstrap-server broker-ip:port --topic topic-name --max-messages 1 --partition 54 --offset 90012464

Tailing Kafka topic in real time

./kafka-console-consumer.sh --bootstrap-server broker-ip:port --topic topic-name

Set a ConsumerGroup offset to latest

./kafka-consumer-groups.sh --bootstrap-server server:port --group group-name --topic topic-name -reset-offsets --to-latest --execute