This is an automated email from the ASF dual-hosted git repository.
yong pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 79233ae Fix deleteTransactionMarker memory leak (#9752)
new bad716e Able to handling messages with multiple listener threads in
order for the Key_Shared subscription. (#9329)
new a1ef8a8 Fixed hasMessageAvailable() with empty topic (#9652)
new b0f8e4a Add original info when publishing message to dead letter
topic (#9655)
new 08fbbcc BugFix : Use Atomic Field Updater to increment volatile
messagesConsumedCounter (#9656)
new 099a49e [Compression] Fix ByteBuffer allocate error in the
AirliftUtils (#9667)
new 5e9132d Duplicate key __pfn_input_topic__ in presto server (#9686)
new ddd77c9 Fix marking individual deletes as dirty (#9732)
new 8f2ea49 Keep the command max-subscriptions style consistent (#9750)
The 8 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:
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 6 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 87 +++++++-
.../apache/pulsar/broker/service/ServerCnx.java | 53 +++--
.../apache/pulsar/client/impl/RawReaderImpl.java | 2 +-
.../pulsar/client/api/DeadLetterTopicTest.java | 58 +++++
.../client/api/KeySharedSubscriptionTest.java | 70 ++++++
.../pulsar/client/api/ProducerConsumerBase.java | 6 +
.../apache/pulsar/client/api/TopicReaderTest.java | 67 +++++-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 7 +
.../pulsar/admin/cli/PulsarAdminToolTest.java | 6 +-
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 2 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 6 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 7 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 70 +++++-
.../apache/pulsar/client/impl/ConsumerImpl.java | 240 +++++++++++----------
.../client/impl/MultiTopicsConsumerImpl.java | 79 +++----
.../pulsar/client/impl/MultiTopicsReaderImpl.java | 6 +-
.../impl/PatternMultiTopicsConsumerImpl.java | 7 +-
.../pulsar/client/impl/PulsarClientImpl.java | 18 +-
.../org/apache/pulsar/client/impl/ReaderImpl.java | 7 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 10 +-
.../pulsar/client/util/ExecutorProvider.java | 21 ++
.../pulsar/client/impl/ClientTestFixtures.java | 5 +
.../pulsar/client/impl/ConsumerImplTest.java | 8 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 16 +-
.../apache/pulsar/client/impl/ReaderImplTest.java | 3 +-
.../apache/pulsar/common/api/proto/PulsarApi.java | 96 +++++++++
.../pulsar/common/api/raw/RawMessageImpl.java | 3 +-
.../pulsar/common/compression/AirliftUtils.java | 4 +-
.../common/compression/CompressionCodecLZ4.java | 2 +-
.../common/compression/CompressionCodecSnappy.java | 2 +-
.../common/compression/CompressionCodecZstd.java | 2 +-
.../apache/pulsar/common/protocol/Commands.java | 5 +-
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
.../pulsar/common/api/raw/RawMessageImplTest.java | 45 ++++
.../common/compression/CompressorCodecTest.java | 38 +++-
36 files changed, 802 insertions(+), 263 deletions(-)
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/api/raw/RawMessageImplTest.java
