Adapter for communicating from Scala to Kafka via case classes - View it on GitHub