List consumer group lag

Show per-partition lag for a consumer group

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

More kafka commands

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
Alter topic partitions

kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12

Increase partition count (cannot decrease)
Describe topic config

kafka-configs.sh --bootstrap-server kafka:9092 --describe --entity-type topics --entity-name my-topic

Show all overridden config values for a topic