Fredo,
Yes, setting "auto.offset.reset=largest" should allow the consumer to reset
the fetching offset to log end when this happens. And if your consumer keep
lagging frequently you probably should consider either increase parallelism
on consumer clients or increase log.retention for the specific
This problem is caused by that the consumer offset lag producer offset,
and the messages are deleted, then i use the lagged offset of fetch
messages.But those messages have been deleted.
Can this be resoled with using `auto.offset.reset=largest` ?
2015-12-24 16:32 GMT+08:00 Fredo Lee :
> When u
