change for kafka-0.8