commit | 22e1978458908ee28dd2e6bf6d3e3af8ff894bb5 | [log] [tgz] |
---|---|---|
author | feynmanlin <feynmanlin@tencent.com> | Mon Aug 17 21:08:37 2020 +0800 |
committer | GitHub <noreply@github.com> | Mon Aug 17 21:08:37 2020 +0800 |
tree | ce4615de248ca085326d262a7283e0133395d937 | |
parent | 397ee00e51b44c0dbbda023398e6ea00e71e2192 [diff] |
Support acknowledging a list of messages (#7688) Fixes #7626 ### Motivation Expose `MessagesImpl` ,so that we can ack list of messages by using `CompletableFuture<Void> acknowledgeAsync(Messages<?> messages)` ### Modifications Change the visibility level of the method from protect to public ### Verifying this change unit test: org.apache.pulsar.client.api.ConsumerBatchReceiveTest#testBatchAck