Download a binary package of Apache Kafka (e.g., kafka_2.13-2.8.0.tgz) from https://kafka.apache.org/downloads and upzip it.
In the Terminal, cd to the unzip folder, and start Kakfa with the following commands (each in a separate Terminal session):
./bin/zookeeper-server-start.sh./bin/kafka-server-start.shDownload a binary package of Apache Kafka (e.g., kafka_2.13-2.8.0.tgz) from https://kafka.apache.org/downloads and unzip it to
such a directory as C:\kafka—Windows does not like a complex path name (!).
In the configuration file C:\kafka\config\zookeeper.properties, comment out the line "dataDir=/tmp/zookeeper". In C:\kafka\config\server.properties, change the line "log.dirs=/tmp/kafka-logs" to "log.dirs=.kafka-logs".
Use the following two commands in the Windows CMD (one in each window) to start Kafka:
C:\kafka\bin\windows\zookeeper-server-start.bat C:\kafka\config\zookeeper.propertiesC:\kafka\bin\windows\kafka-server-start.bat C:\kafka\config\server.propertiesSometimes you need to clean up data in the Kafka topics to start over. For this purpose, in Linux/MacOS, delete the folders /tmp/zookeeper, /tmp/kafka-logs and /tmp/kafka-streams. In Windows, delete the folders C:\kafka\.dataDirzookeeper and C:\kafka\.kafka-logs.
The producer gets Appliance JSON data from a public API and
publishes it to a Kafka topic named "appliance-topic".
The processor subscribes to that Kafka topic, computes a total count for each (appliance) Brand
and publishes the results to another Kafka topic named "brand-topic".
The processor also implements an interactive query service that allows users to query the results via REST.
The consumer subscribes to "brand-topic" and logs the records.
After running the producer and processor,
get a list of Brand names with the following URL:
http://localhost:8183/brands/allThen, use the following URL and refresh it to get the updating result for a Brand (e.g. IKEA):
http://localhost:8183/brand/IKEA/quantity