Upgraded to kafka 0.8