Apache Kafka Producer and Consumer which uses Spark-Streaming and Avro Serialization written in Scala.