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 a94dbe6 [pulsar-admin] Perfect judgment conditions of pulsar-admin
(#12315)
new 97c79e2 Enable CLI to publish non-batched messages (#12641)
new 74c91a3 [Authorization] Support GET_METADATA topic op after enable
auth (#12656)
new 5e2657a [Config] Add readWorkerThreadsThrottlingEnabled to
conf/bookkeeper.conf (#12666)
new 985ef03 [pulsar-admin] Print topic internal info as formatted json
(#12709)
new 3c9894d [Managed Ledger] Fix the incorrect total size when
BrokerEntryMetadata is enabled (#12714)
new 0d2022d Even if always compatible is set, Consumers cannot be created
(#12721)
new 2ab4dec [Authorization] Support UNSUBSCRIBE namespace op after enable
auth (#12742)
new 230e1ac [Issue 12723] Fix race condition in
PersistentTopic#addReplicationCluster (#12729)
new d09854f [Java Client] Let producer reconnect for state
RegisteringSchema (#12781)
new c43d1da [Pulsar SQL] Handle message null schema version in
PulsarRecordCursor (#12809)
new 0016151 Fix TopicPoliciesCacheNotInitException issue. (#12773)
new fdcf5a4 Fix cherry-pick issue
The 12 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:
conf/bookkeeper.conf | 5 +
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 1 +
.../authorization/PulsarAuthorizationProvider.java | 2 +
.../SystemTopicBasedTopicPoliciesService.java | 42 +++++---
.../broker/service/persistent/PersistentTopic.java | 6 +-
.../service/schema/SchemaRegistryServiceImpl.java | 3 +
.../broker/service/BrokerEntryMetadataE2ETest.java | 47 +++++++++
.../SystemTopicBasedTopicPoliciesServiceTest.java | 40 ++++++++
.../api/AuthorizationProducerConsumerTest.java | 42 +++++++-
.../SchemaCompatibilityCheckTest.java | 22 +++++
.../pulsar/client/cli/PulsarClientToolTest.java | 46 ++++++++-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 5 +-
.../org/apache/pulsar/client/cli/CmdProduce.java | 5 +
.../pulsar/client/impl/ConnectionHandler.java | 1 +
.../util/collections/ConcurrentOpenHashMap.java | 26 +++++
.../collections/ConcurrentOpenHashMapTest.java | 32 ++++++
.../pulsar/sql/presto/PulsarRecordCursor.java | 42 ++++++--
.../sql/presto/PulsarSqlSchemaInfoProvider.java | 9 +-
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 107 ++++++++++++++++++++-
.../coordinator/impl/MLTransactionLogImpl.java | 8 +-
site2/docs/reference-cli-tools.md | 1 +
21 files changed, 456 insertions(+), 36 deletions(-)
