This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from b55bba3 Fix cherry-pick check style issue
new e904735 Support retry when creating reader of Topic Policies (#12622)
new 736dd6a [Python Schema] Python schema support custom Avro
configurations for Enum type (#12642)
new 006d42e [broker] remove useless method
"PersistentTopic#getPersistentTopic" (#12655)
new c4e491b [pulsar-admin] Perfect judgment conditions of pulsar-admin
(#12315)
new bb86877 [pulsar-admin] Add corresponding get command for namespace
(#12322)
new 02b2e3e Enable CLI to publish non-batched messages (#12641)
new 85757732 ### Motivation (#12698)
new 905f54a [pulsar-client] Fix pending queue-size stats for batch
messages (#12704)
new 0008873 [pulsar-admin] Print topic internal info as formatted json
(#12709)
new d584b98 Remove unused code in PersistentTopic.java (#12715)
new 37628b5 Remove unnecessary powermock annotation (#12713)
new d7ae988 Remove catching `NamingException`. (#12725)
new a813c52 [pulsar-broker] Handle lookup redirect for V1-topics with
different cluster (#12743)
new a9e8b3f Even if always compatible is set, Consumers cannot be created
(#12721)
new 1ca6946 [pulsar-admin] Add --all option to get all version schema of
topic (#12535)
new b6ae157 remove redundant placeholders (#12717)
new 502f143 remove unnecessary string operation (#12719)
new 5d36976 [Issue 12723] Fix race condition in
PersistentTopic#addReplicationCluster (#12729)
new e35b561 Remove unnecessary boxing unboxing (#12790)
The 19 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/tests/FailFastNotifier.java | 2 +-
.../tests/FastThreadLocalCleanupListener.java | 2 +-
.../pulsar/tests/MockitoCleanupListener.java | 2 +-
.../pulsar/tests/ThreadLeakDetectorListener.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 10 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 2 +-
.../authentication/AuthenticationProviderList.java | 2 +-
.../authorization/PulsarAuthorizationProvider.java | 23 +--
.../pulsar/broker/resources/ClusterResources.java | 4 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 24 +++
.../broker/admin/impl/PersistentTopicsBase.java | 2 +-
.../apache/pulsar/broker/admin/v1/Namespaces.java | 65 ++++++++
.../apache/pulsar/broker/admin/v2/Namespaces.java | 59 +++++++
.../apache/pulsar/broker/cache/BundlesQuotas.java | 2 +-
.../org/apache/pulsar/broker/rest/TopicsBase.java | 4 +-
.../pulsar/broker/service/BrokerService.java | 2 +-
.../SystemTopicBasedTopicPoliciesService.java | 23 ++-
.../broker/service/persistent/PersistentTopic.java | 13 +-
.../broker/service/persistent/SystemTopic.java | 4 +-
.../service/schema/SchemaRegistryServiceImpl.java | 3 +
.../buffer/impl/InMemTransactionBuffer.java | 2 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 4 -
.../pulsar/broker/admin/TopicPoliciesTest.java | 2 +-
.../org/apache/pulsar/broker/admin/TopicsTest.java | 4 -
.../pulsar/broker/auth/AuthorizationTest.java | 6 +
.../broker/intercept/CounterBrokerInterceptor.java | 8 +-
.../BrokerServiceAutoSubscriptionCreationTest.java | 19 ++-
.../BrokerServiceAutoTopicCreationTest.java | 37 +++--
.../pulsar/broker/service/ReplicatorTest.java | 21 +++
.../SystemTopicBasedTopicPoliciesServiceTest.java | 34 +++++
...ntStickyKeyDispatcherMultipleConsumersTest.java | 2 -
.../persistent/PersistentSubscriptionTest.java | 7 -
.../StreamingEntryReaderTests.java | 10 --
.../api/AuthorizationProducerConsumerTest.java | 7 +
.../client/api/SimpleProducerConsumerStatTest.java | 7 +-
.../pulsar/compaction/CompactedTopicTest.java | 70 ++++++++-
.../SchemaCompatibilityCheckTest.java | 22 +++
.../org/apache/pulsar/client/admin/Namespaces.java | 81 ++++++++++
.../client/admin/internal/NamespacesImpl.java | 170 +++++++++++++++++++++
.../pulsar/client/admin/internal/TopicsImpl.java | 2 +-
.../client/impl/auth/AuthenticationAthenz.java | 2 +-
pulsar-client-cpp/python/examples/company.avsc | 4 +-
pulsar-client-cpp/python/pulsar/schema/__init__.py | 2 +-
.../python/pulsar/schema/definition.py | 18 ++-
pulsar-client-cpp/python/schema_test.py | 118 +++++++-------
.../pulsar/admin/cli/PulsarAdminToolTest.java | 71 +++++++++
.../pulsar/client/cli/PulsarClientToolTest.java | 46 +++++-
.../src/test/resources/test_schema_create.json | 4 +
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 65 ++++++++
.../org/apache/pulsar/admin/cli/CmdSchemas.java | 22 ++-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 5 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 19 ++-
.../org/apache/pulsar/client/cli/CmdProduce.java | 5 +
.../client/impl/MultiTopicsConsumerImpl.java | 2 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 10 +-
.../org/apache/pulsar/common/net/ServiceURI.java | 2 +-
.../pulsar/common/tls/TlsHostnameVerifier.java | 2 +-
.../util/collections/ConcurrentOpenHashMap.java | 26 ++++
.../policies/data/loadbalancer/BrokerUsage.java | 4 +-
.../collections/ConcurrentOpenHashMapTest.java | 32 ++++
.../triggers/WatermarkCountTriggerPolicy.java | 2 +-
.../windowing/WindowFunctionExecutorTest.java | 2 +-
.../functions/utils/FunctionConfigUtils.java | 2 +-
.../functions/worker/FunctionMetaDataManager.java | 2 +-
.../functions/worker/rest/api/ComponentImpl.java | 7 +-
.../pulsar/io/cassandra/CassandraAbstractSink.java | 2 +-
.../primitive/PulsarPrimitiveRowDecoder.java | 6 +-
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 2 +-
.../decoder/primitive/TestPrimitiveDecoder.java | 2 +-
.../pulsar/testclient/DefaultMessageFormatter.java | 2 +-
.../apache/pulsar/websocket/ConsumerHandler.java | 2 +-
site2/docs/reference-cli-tools.md | 1 +
.../provider/TieredStorageConfiguration.java | 4 +-
74 files changed, 1059 insertions(+), 205 deletions(-)
create mode 100644
pulsar-client-tools-test/src/test/resources/test_schema_create.json
