# kafka location on container
/opt/kafka

# create topic
bin/kafka-topics.sh --create --topic topic_name --bootstrap-server localhost:9092

# list topics
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

# produce message
bin/kafka-console-producer.sh --topic topic_name --bootstrap-server localhost:9092

# consume message
bin/kafka-console-consumer.sh --topic prometheus-events --bootstrap-server localhost:9092 --from-beginning