Steps for execution and corresponding explanation:
- Download Confluent Open Source from https://www.confluent.io/download/ (Tested on v5.0).
- Extract it and inside the directory, run the following command: bin/confluent start
- This will start Kafka, Schema Registry, Zookeeper etc.
- Create Topic using the following command which has the name 'excel': bin/kafka-topics --create --zookeeper localhost:2181 \ --replication-factor 1 --partitions 1 --topic excel
- Run MainP.java which is a Kafka Producer which writes a .csv file to the topic created.
- Run MainC.java which is a Kafka Consumer which reads the data from the topic.