Re: Kafka offset out of range using SimpleConsumer Example

2016-08-12 Thread Ryan Thompson
#1 turned out to be invalid, my logging was simply bad (I was logging the number of messages I'd read so far for that partition, not the requested read offset) #2 is still valid, though. I'm thinking that a possible explanation might be that the part of the log I was processing was deleted, but I

Kafka offset out of range using SimpleConsumer Example

2016-08-11 Thread Ryan Thompson
Hello, I've implemented something quite similar to the SimpleConsumer example on https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example I'm using it to traverse a specific range of offsets. I find that sometimes, in the middle of this traversal, I end up hitting an "Offse