Hi, I am running kafka 0.8.2.1 and we have some consumers that is using kafka to store its offsets (offsets.storage=kafka). About once a week the consumer will see the exception OffsetsLoadInProgressException and when the exception goes away the consumer is reset the the earliest offset. It does not affect all of the consumers at the same time.
What causes OffsetsLoadInProgressException to happen? Did the offset manager change? Would the ConsumerConnector start reading from the earliest offset if OffsetsLoadInProgressException is thrown? Thanks, Tom
