dao-jun commented on issue #20099: URL: https://github.com/apache/pulsar/issues/20099#issuecomment-2124375570
The problem is Pulsar optimized `consumer.ack`. When you call `consumer.ack`, the `ack` request will not send to the broker immediately, but cached in the client. When the cached ack requests reached the threshold, send them to the broker in batch. If you unload the topic when the ack requests didn't send to the broker, you will receive duplicated messages. -- 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]
