Upgrade to Kafka_2.10_0.8.1.1