lhotari commented on issue #23193: URL: https://github.com/apache/pulsar/issues/23193#issuecomment-3540751918
This should be handled in a way where org.apache.pulsar.client.impl.ConsumerBase#callMessageListener checks the status of the consumer and doesn't process the message if the state of the consumer is Closing or Closed. This change would also prevent duplicate processing that currently occurs with message listeners when the consumer is closing. The messages get buffered in the message listener executor and would get processed regardless of the consumer state. Since the message cannot be acknowledged, that will result in duplicate processing. -- 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]
