Moved support to Kafka 0.8.1