Produce messages kafka
Send messages to a topic interactively from stdin
kafka-console-producer.sh --bootstrap-server kafka:9092 --topic <name>
more kafka
all 20 commands →
List consumer groups
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --list
Consumer group lag
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group <group>
Reset consumer group offset
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group <group> --topic <topic> --reset-offsets --to-earliest --execute
Alter topic partitions
kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic <name> --partitions 6
Get topic offsets
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka:9092 --topic <name>