Get topic offsets

Show earliest and latest offsets per partition

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka:9092 --topic <name>

More kafka commands

Create a topic

kafka-topics.sh --bootstrap-server kafka:9092 --create --topic my-topic --partitions 6 --replication-factor 3

Create a new Kafka topic with 6 partitions and RF=3
List consumer group lag

kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group my-group

Show per-partition lag for a consumer group
Reset consumer group offset

kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute

Reset consumer offsets to earliest
Produce messages from stdin

kafka-console-producer.sh --bootstrap-server kafka:9092 --topic my-topic --property 'key.separator=:' --property 'parse.key=true'

Produce key:value messages interactively
Consume from beginning

kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic my-topic --from-beginning --max-messages 10

Read first 10 messages from a topic