Reset offset to :earliest_offset whenever OffsetOutOfRange happens

bpot / poseidon

A client for Kafka 0.8

MIT License

260 stars 101 forks source link

Reset offset to :earliest_offset whenever OffsetOutOfRange happens #102

Open ymattw opened 9 years ago

ymattw commented 9 years ago

OffsetOutOfRange error can also happen when the returned offset is a positive number but corresponding messages started from the offset were retentioned