You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

14 lines
443 B

# 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