Integration test of Apache Kafka 0.9.0+ and Java clients. - View it on GitHub