This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7f345a6 [pulsar-client] remove consumer reference from PulsarClient
on subscription failure (#11758)
new e49177c Fixed race condition on multi-topic consumer (#11764)
new a6d94e5 Producer getting producer busy is removing existing producer
from list (#11804)
new 321be3c [pulsar-client] Refactor seek to reuse common logic. (#9670)
new 454e93e Fix seek at batchIndex level receive duplicated messages
(#11826)
new 18b36d6 Print position info when can't find next valid position.
(#11969)
new 141f250 Fix wrong key-hash selector used for new consumers after all
the previous consumers disconnected (#12035)
new bae19a7 Fixed used after recycle issue in OpAddEntry (#12103)
new fedea13 Remove the deprecated api usage in hdfs (#12080)
new 68d6479 Upgrade netty to 4.1.68.Final (#12218)
new d846b43 Optimize the memory usage of Cache Eviction (#12045)
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
buildtools/pom.xml | 7 ++
distribution/server/src/assemble/LICENSE.bin.txt | 36 +++---
.../mledger/impl/ManagedCursorContainer.java | 38 +++++--
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 33 ++++--
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 13 ++-
.../mledger/impl/ManagedCursorContainerTest.java | 42 ++++++-
pom.xml | 4 +-
.../org/apache/pulsar/broker/service/Producer.java | 5 +-
.../apache/pulsar/broker/service/ServerCnx.java | 18 +++
...istentStickyKeyDispatcherMultipleConsumers.java | 42 +++++++
.../nonpersistent/NonPersistentSubscription.java | 36 ++----
...istentStickyKeyDispatcherMultipleConsumers.java | 10 +-
.../service/persistent/PersistentSubscription.java | 10 +-
.../broker/service/PersistentTopicE2ETest.java | 45 ++++++++
.../broker/service/SubscriptionSeekTest.java | 83 ++++++++++++++
.../client/api/KeySharedSubscriptionTest.java | 71 +++++++++++-
.../apache/pulsar/client/impl/ConsumerImpl.java | 126 +++++++++------------
.../client/impl/MultiTopicsConsumerImpl.java | 5 +
.../pulsar/io/hdfs2/AbstractHdfsConnector.java | 7 +-
.../io/hdfs2/sink/seq/HdfsSequentialTextSink.java | 2 +-
.../pulsar/io/hdfs3/AbstractHdfsConnector.java | 7 +-
.../io/hdfs3/sink/seq/HdfsSequentialTextSink.java | 2 +-
pulsar-sql/presto-distribution/LICENSE | 28 ++---
23 files changed, 488 insertions(+), 182 deletions(-)
