kafka start kafka docker image sudo docker-compose up -d login into the container sudo docker exec -it kafka_kafka_1 /bin/bash create kafka topic /bin/kafka-topics --create --topic my-events --bootstrap-server localhost:9092 produce messages to a given topic /bin/kafka-console-producer --topic my-events --bootstrap-server localhost:9092 event 1 event 2 event 3 event4 <ctrl+c> consume all messages from the topic /bin/kafka-console-consumer --topic my-events --from-beginning --bootstrap-server localhost:9092 consume messages with a given offset /bin/kafka-console-consumer --topic my-events --offset 10 --partition 0 --bootstrap-server localhost:9092 number of messages in the topic /bin/kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic my-events