I previously thought that call readMoreEntries() should wait for callbacks complete. so the client must wait for callbacks complete.
After discuss with Jia Zhai, we thought that readMoreEntries() should wait for callbacks complete but client do not need to wait callbacks complete. But another problem is when to call readMoreEntries(). on every callback? or pending the callbacks then readMoreEntries() only once. Another possible issue is when client send redeliverUnacknowledgedMessages request in a very short time, messages replay to the consumer reduplicate possible. [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2400 ] This message was relayed via gitbox.apache.org for [email protected]
