migrate to Kafka version 0.8.1. Fix changes in api. Tests pass