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 72f7785 fix batch size < 0 error when peekmessage (#11301)
add 5aee599 [broker] Fix issue that message ordering could be broken when
redelivering messages on Key_Shared subscription (#10762)
No new revisions were added by this update.
Summary of changes:
...ConsistentHashingStickyKeyConsumerSelector.java | 4 +-
.../org/apache/pulsar/broker/service/Consumer.java | 18 +-
...ashRangeAutoSplitStickyKeyConsumerSelector.java | 4 +-
...ashRangeExclusiveStickyKeyConsumerSelector.java | 9 +-
.../broker/service/StickyKeyConsumerSelector.java | 17 +-
.../persistent/MessageRedeliveryController.java | 120 ++++++++++++
.../PersistentDispatcherMultipleConsumers.java | 75 +++++---
...istentStickyKeyDispatcherMultipleConsumers.java | 31 ++-
...istentStreamingDispatcherMultipleConsumers.java | 4 +-
.../broker/service/PersistentTopicE2ETest.java | 21 +-
.../MessageRedeliveryControllerTest.java | 213 +++++++++++++++++++++
...ntStickyKeyDispatcherMultipleConsumersTest.java | 133 +++++++++++++
12 files changed, 580 insertions(+), 69 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryControllerTest.java
