codelipenghui opened a new pull request #12530: URL: https://github.com/apache/pulsar/pull/12530
The WebSocket proxy uses the consumer instance to process the message acknowledgment. But for the batch message acknowledgment, the batch message instance that deserialized from WebSocket proxy will with the same batch message acker, which will lead to the batch message can't be acked because the consumer only sends the ack request to the broker while the acker becomes empty. The fix is to introduce a map to maintain an original which is used for getting batch message acker. Added the test for covering the batch message ack. -- 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]
