This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 84703ace1b4 [improve][doc] Improve the JavaDocs of sendAsync to avoid
improper use (#24601)
new b671819ac0d [improve][io] Add dependency file name information to
error message when .nar file validation fails with ZipException (#24604)
new d2b2942d8e0 [improve][broker]Remove block calling that named
cursor.asyncGetNth when expiring messages (#24606)
new 9f3efa5f460 [fix][client]Prevent ZeroQueueConsumer from receiving
batch messages when using MessagePayloadProcessor (#24610)
new 828d4ff9571 [fix][broker] Fix duplicate watcher registration after
SessionReestablished (#24621)
new 9efee01ef28 [fix][proxy] Fix TooLongFrameException with Pulsar Proxy
(#24626)
The 5 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:
.../pulsar/broker/service/MessageExpirer.java | 3 +
.../broker/service/PulsarChannelInitializer.java | 6 +-
.../nonpersistent/NonPersistentSubscription.java | 6 ++
.../persistent/PersistentMessageExpiryMonitor.java | 6 ++
.../service/persistent/PersistentReplicator.java | 17 ++++
.../service/persistent/PersistentSubscription.java | 20 ++++
.../broker/service/persistent/PersistentTopic.java | 41 +++++++-
.../service/PersistentMessageFinderTest.java | 110 +++++++++++++++++++++
.../pulsar/broker/service/ReplicatorTest.java | 30 ++++++
.../pulsar/client/api/MockBrokerService.java | 4 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 68 +++++++++++++
.../PulsarFunctionTestTemporaryDirectory.java | 4 +
.../apache/pulsar/io/AbstractPulsarE2ETest.java | 3 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 24 ++++-
.../org/apache/pulsar/client/api/Consumer.java | 25 +++--
.../apache/pulsar/client/api/ConsumerBuilder.java | 32 +++++-
.../org/apache/pulsar/client/impl/ClientCnx.java | 5 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 2 +-
.../client/impl/PulsarChannelInitializer.java | 8 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 36 +++++--
.../pulsar/common/protocol/FrameDecoderUtil.java | 67 +++++++++++++
.../functions/utils/FunctionFilePackage.java | 3 +-
.../pulsar/metadata/impl/ZKMetadataStore.java | 7 +-
.../org/apache/pulsar/metadata/ZKSessionTest.java | 49 +++++++++
.../pulsar/proxy/server/DirectProxyHandler.java | 25 ++---
.../proxy/server/ServiceChannelInitializer.java | 7 +-
26 files changed, 544 insertions(+), 64 deletions(-)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/FrameDecoderUtil.java
