This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from c5ae308ceb1 Example broke Ensemble>=WriteQuorum>=AckQuorum (#17956)
add 12e78b26c5a [fix][client] Messages with inconsistent consumer epochs
are not filtered when using batch receive and trigger timeout. (#17318)
No new revisions were added by this update.
Summary of changes:
.../pulsar/client/api/MultiTopicsConsumerTest.java | 39 ++++
.../pulsar/client/impl/MessageRedeliveryTest.java | 196 +++++++++++++++++++--
.../apache/pulsar/client/impl/ConsumerBase.java | 9 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 150 +++++++---------
.../client/impl/MultiTopicsConsumerImpl.java | 54 ++----
.../impl/UnAckedMessageRedeliveryTracker.java | 43 +++--
6 files changed, 312 insertions(+), 179 deletions(-)
