Moving Kafka to its own module to support Kafka 0.7.x and Kafka 0.8.x