Initial support for kafka-0.8.x