migrate to kafka 0.8