update code to pass test; consumes messages but clj-kafka.consumer.zk/messages can't map the contents for us...