Kafka consumer & producer for scalaz-stream - View it on GitHub