Kafka 0.8

Deltas needed to support the new API for Kafka 0.8