nodece opened a new pull request, #25528: URL: https://github.com/apache/pulsar/pull/25528
#### Motivation The broker ack path could update in-memory consumer ack state before the underlying subscription ack completed successfully. That makes ack failures harder to reason about and can lead to inconsistent broker-side state, especially when ack receipts are expected to reflect durable success. #### Changes - add an async-first subscription ack API and route broker ack handling through it - defer broker-side ack memory updates in `Consumer` until the ack operation succeeds while keeping the existing helper-based logic shape close to the original code - propagate persisted ack waiting from `ServerCnx` for request-id based ack receipts - update persistent, non-persistent, replicated, dispatcher, pending-ack, and compactor subscription paths to use the async ack API - adjust broker tests and fix `PersistentTopicTest#testCompactorSubscription` mock setup for the compactor ledger context -- 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]
