This project is an assignment that creates and reads streaming data from Kafka and presents the result on the screen and is written in Golang using a dockerized Kafka and Zookeeper. According to the assignment paper, the created data is in the form of (key, average value) pairs. There is a topic named avg (as explained in Section 2). The results are in a table form includes token, sum, count and average (update time every second).
bash run.sh