eolivelli commented on issue #16421: URL: https://github.com/apache/pulsar/issues/16421#issuecomment-1177365957
with batch messages we fall into this case: https://github.com/apache/pulsar/blob/8b1d7a0c894c3124db99302e60e0e523a55dc3b2/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java#L625 basically the dispatcher reads N entries from Storage (BK or Offloader) and the Consumer does not have enough permits, so we are throwing away part of the entries that we read. Those entries are added to the list of "messages to replay" and so they will be read again from storage next time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
