Open jackerlj opened 6 years ago
public void fail(long offset) { failedOffsets.remove(offset); }
ack fail时只是从failedOffsets中移除这个offset (这个failedOffsets中有值么,什么时候add进去的),pendingOffsets中也存在这个offset,不移除该offset是否会导致zookeeper中offset变成该值而不更新?
ack fail时只是从failedOffsets中移除这个offset (这个failedOffsets中有值么,什么时候add进去的),pendingOffsets中也存在这个offset,不移除该offset是否会导致zookeeper中offset变成该值而不更新?