A few concurrent issues:
1. We did not pick a specific version of Kafka in our pom, instead we just dependended on 0.9+
2. It looks like Kafka has deployed a 0.10 snapshot
3. For some reason, our build is picking up snapshot versions instead of using only things available on Maven central.
4. 0.10 version of KafkaIO has a breaking change that breaks our code.