openshift-kafka - fork

Run Apache Kafka and Apache ZooKeeper on OpenShift v3.

---

Project maintained by rondinif Hosted on GitHub Pages — Theme by mattgraham

Quick Start Explained ( part 4 of 4)

Follow the Apache Kafka Documentation Quick Start

1. Create a topic

bin/kafka-topics.sh --create --zookeeper apache-kafka --replication-factor 1 --partitions 1 --topic test

1. List topics

bin/kafka-topics.sh --list --zookeeper apache-kafka

1. Send some messages

bin/kafka-console-producer.sh --broker-list apache-kafka:9092 --topic test <<EOF
foo
bar
baz
EOF

1. Receive some messages

bin/kafka-console-consumer.sh --bootstrap-server apache-kafka:9092 --topic test --from-beginning

Credits

• This is based on work original by Jim Minter and a fork of https://github.com/mattf/openshift-kafka by Matthew Farrellee

---

back to the index