recover from Offset Out of Range
Opened this issue · 3 comments
yannick commented
add example to show how to recover from a
Offset 285960896 is out of range for topic mytopic, partition 0
Exception
yannick commented
while #20 solves it somewhat i think it makes application code brutally complicated and its not the right way. you should be able to catch this within the loop where you receive the messages and not outside of the task.
pszturmaj commented
It would need to be rethought and possibly rewritten, currently you need to catch the exception and restart the task with new Consumer instance