Create a topic kafka

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 Alter topic partitions kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12