Small changes to work with different versions of Kafka and Kafka-Storm