Scala wrapper for kafka consumer and producer - View it on GitHub