Switched to a library that supports Kafka 0.8.1