migrate to Kafka version 0.8.1. Fix changes in api. Tests pass
update version of expectations to 1.4.56
exclude messages from expectation to prevent symbol clash