Updating to support kafka 0.8
Updating to support kafka 0.8