initial Kafka 0.8 support