changing to kafka 0.8