#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
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