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 8da9422 Support key_based batch builder for functions and sources
(#8523)
add 8d7dd11 Add key-shared consumer range to internal topic stats. (#8567)
No new revisions were added by this update.
Summary of changes:
...ConsistentHashingStickyKeyConsumerSelector.java | 21 ++++++++
...ashRangeAutoSplitStickyKeyConsumerSelector.java | 18 +++++--
...ashRangeExclusiveStickyKeyConsumerSelector.java | 25 ++++++++++
.../broker/service/StickyKeyConsumerSelector.java | 9 ++++
...istentStickyKeyDispatcherMultipleConsumers.java | 4 ++
.../service/persistent/PersistentSubscription.java | 7 +++
...istentHashingStickyKeyConsumerSelectorTest.java | 29 +++++++++++
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 58 ++++++++++++++++++++++
...angeExclusiveStickyKeyConsumerSelectorTest.java | 34 +++++++++++++
.../pulsar/common/policies/data/ConsumerStats.java | 4 ++
10 files changed, 205 insertions(+), 4 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelectorTest.java
