apache-kafka-java-producer-dw

see: https://cevheribozoglan.medium.com/apache-kafka-digital-wristband-create-kafka-producer-and-consumer-from-linux-terminal-e2ccd2becb06

First, Download Apache Kafka : https://kafka.apache.org/downloads. For example : https://www.apache.org/dyn/closer.cgi?path=/kafka/2.6.0/kafka_2.13-2.6.0.tgz

---

unzip files tar -xzf kafka_2.13-2.6.0.tgz cd kafka_2.13-2.6.0

---

need Java 8+

for debian, ubuntu, mint

sudo apt-get install openjdk-8-jdk

---

Start the Kafka Environment

Open new terminal

bin/zookeeper-server-start.sh config/zookeeper.properties

Open another terminal

bin/kafka-server-start.sh config/server.properties Create digital-wristband topic for example: 1 broker, 5 partitions, 1 replication-factor

Open another terminal

bin/kafka-topics.sh
--create --zookeeper localhost:2181
--replication-factor 1
--partitions 5
--topic digital-wristband Now, the zookeeper is running, a kafka broker is running, and a kafka topic has been created.

---

Now let’s create 1 producer and a consumer from cli and show the relationship between each other.

Open another ""PRODUCER"" terminal

➜ kafka_2.13-2.6.0 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic digital-wristband

Fedora

Open another ""CONSUMER"" terminal

➜ kafka_2.13-2.6.0 bin/kafka-console-consumer.sh --topic digital-wristband --from-beginning --bootstrap-server localhost:9092

---

Now Start the java code

java -cp “/path/to/kafka/kafka_2.11-0.9.0.0/lib/*”:. ProducerDW.java digital-wristband