function that returns a KafkaStream iterator

this is just to avoid getting a kafka.consumer.ConsumerTimeoutException
I'm catching it on common-io, in the call to get-next-message