Upgrading client to 0.10.1.0

2016-10-21 Thread Josh Goodrich
To use the new KafkaConsumer.offsetsForTimes(...) API does the server also need to be upgraded from 0.10.0.1? Josh

KafkaConsumer poll(timeout) doesn't seem to work as expected

2016-07-13 Thread Josh Goodrich
The poll(timeout) method of the Java KafkaConsumer API doesn’t behave the way you would think. If you create a new Consumer with a groupId that has been seen before, even if there are new events in the topic if you issue a poll(0) it never returns any records. I find I have to put in a loop of 2