This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from e5a5498 [Python Schema] Support setting namespace for python schema
(#12175)
new cd2dd06 [pulsar-client] Make it possible to disable poolMessages
(#12108)
new 90c3804 Fix deadLetterPolicy is not working with key shared
subscription under partitioned topic (#12148)
new e0d3d421 Remove the deprecated api usage in hdfs (#12080)
new 519dbe1 [testclient] Call printAggregatedStats method before client
exit (#11985)
new 2fe6cba [testclient] Add total messages when printing throughput
(#12084)
new 9f39cc6 Fix returned wrong hash ranges for the consumer with same
consumer name (#12212)
new f2cc522 Disable stats recorder for built-in PulsarClient (#12217)
new 9ec4f90 [Python] Do not sort schema fields by default (#12232)
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:
.../org/apache/pulsar/broker/PulsarService.java | 2 +
...ConsistentHashingStickyKeyConsumerSelector.java | 9 +-
...ashRangeAutoSplitStickyKeyConsumerSelector.java | 9 +-
...ashRangeExclusiveStickyKeyConsumerSelector.java | 9 +-
.../broker/service/StickyKeyConsumerSelector.java | 3 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 3 +-
.../service/persistent/PersistentSubscription.java | 10 ++-
...istentHashingStickyKeyConsumerSelectorTest.java | 29 +++++--
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 40 +++++++--
...angeExclusiveStickyKeyConsumerSelectorTest.java | 48 +++++++++--
.../pulsar/client/api/DeadLetterTopicTest.java | 96 ++++++++++++++++++++++
.../java/org/apache/pulsar/client/api/Range.java | 19 +++++
.../python/pulsar/schema/definition.py | 19 +++--
pulsar-client-cpp/python/schema_test.py | 38 +++++++++
.../org/apache/pulsar/client/cli/CmdConsume.java | 2 +-
.../client/impl/MultiTopicsConsumerImpl.java | 3 +-
.../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 +-
.../proxy/socket/client/PerformanceClient.java | 40 ++++++++-
.../pulsar/testclient/ManagedLedgerWriter.java | 34 ++++++--
.../pulsar/testclient/PerformanceReader.java | 6 +-
23 files changed, 366 insertions(+), 71 deletions(-)
