Get topic offsets kafka
Show earliest and latest offsets per partition
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka:9092 --topic <name>
more kafka
all 20 commands →
Create a topic
kafka-topics.sh --bootstrap-server kafka:9092 --create --topic my-topic --partitions 6 --replication-factor 3
List consumer group lag
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group my-group
Reset consumer group offset
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute
Produce messages from stdin
kafka-console-producer.sh --bootstrap-server kafka:9092 --topic my-topic --property 'key.separator=:' --property 'parse.key=true'
Consume from beginning
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic my-topic --from-beginning --max-messages 10