An example implementation of kafka data pipeline in scala.

The application consists of a DataProducer class that publishes message to a kafka cluster and a DataConsumer class which consumes the data from kafka cluster.

To run the application we need a running kafka-cluster and sbt installed in our system.

• execute the DataConsumer class is a terminal via sbt using the command : runMain DataConsumer localhost:9092 test quickstart
• executed the DataProducer class in another terminal via sbt using the command : runMain DataProducer 3 quickstart localhost:9092