#The project showcases an optimal way of writing multi threaded Kafka consumer covering possible edge cases.
#Multi threading consumers ,considering partition as unit of task and thread per partition model.
#Taking care of tracking the offsets.
#Handling partition rebalances.
#etc.
To run a kafka broker
docker prune docker-compose up
To visualize the kafka data
To execute
mvn clean install
Run the following class
Driver.java
