Oh, I thought that if the last redeliverUnacknowledgedMessages is return but callbacks not complete yet, then another redeliverUnacknowledgedMessages is coming, if last messagesToReplay is not delete yet, so that current messagesToReplay has the last messagesToReplay items. And, I thought that call readMoreEntries() should wait for callbacks complete.
[ Full content available at: https://github.com/apache/incubator-pulsar/pull/2400 ] This message was relayed via gitbox.apache.org for [email protected]
