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 fc7cba4 [pulsar-broker] Add stop replicator producer logic when start
replicator cluster failed. (#12724)
new 92e1069 [tools] fix TestRunMain test (#12675)
new d040942 ### Motivation (#12698)
new f32ddc4 [Python] Provide __str__ operator for BytesSchema (#12593)
new 3657203 Reduced severity of log "refreshing key manager" in
KeyManagerProxy (#12594)
new 38b1bbd fix log typo in NamespaceService#checkHeartbeatNamespace and
NamespaceService#checkHeartbeatNamespaceV2 (#12582)
new eccacaf Fix invalid firstSentAt value (#12588)
new 361c4c1 add additional error handling in auto partition update task
MultiTopicsConsumerImpl (#12620)
new 4e0e772 allow consume permission to do GetTopics op (#12600)
new 8e3c702 modify check waitingForPingResponse with volatile (#12615)
new 5c51475 Fix String should use equals but not ==. (#12619)
new 6a55136 Support retry when creating reader of Topic Policies (#12622)
new a03609c [pulsar-broker] Add git branch information for PulsarVersion
(#12541)
new e801f93 [Broker] Optimize exception information for schemas (#12647)
new 82c01bc k8s runtime: force deletion to avoid hung function worker
during connector restart (#12504)
new e642a04 [Java Client] Remove invalid call to
Thread.currentThread().interrupt(); (#12652)
The 15 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/functions_worker.yml | 4 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 10 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +-
.../bookkeeper/test/BookKeeperClusterTestCase.java | 2 +-
.../authorization/AuthorizationProvider.java | 10 ++
.../MultiRolesTokenAuthorizationProvider.java | 5 +
.../authorization/PulsarAuthorizationProvider.java | 8 ++
.../org/apache/pulsar/broker/PulsarService.java | 1 +
.../broker/admin/impl/SchemasResourceBase.java | 11 +-
.../pulsar/broker/namespace/NamespaceService.java | 2 +-
.../SystemTopicBasedTopicPoliciesService.java | 23 ++++-
.../broker/auth/MockAuthorizationProvider.java | 6 ++
.../broker/intercept/CounterBrokerInterceptor.java | 8 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 34 ++++++
.../api/AuthorizationProducerConsumerTest.java | 5 +
.../impl/PatternTopicsConsumerImplAuthTest.java | 5 +
.../pulsar/compaction/CompactedTopicTest.java | 70 ++++++++++++-
pulsar-client-cpp/python/pulsar/schema/schema.py | 7 ++
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 5 +
.../org/apache/pulsar/admin/cli/TestRunMain.java | 4 +-
.../client/impl/MultiTopicsConsumerImpl.java | 33 +++---
.../client/impl/PartitionedProducerImpl.java | 30 +++---
.../apache/pulsar/client/impl/ProducerImpl.java | 3 +-
.../org/apache/pulsar/PulsarVersion.java | 4 +
.../pulsar/common/protocol/PulsarHandler.java | 2 +-
.../apache/pulsar/common/util/KeyManagerProxy.java | 9 +-
.../runtime/kubernetes/KubernetesRuntime.java | 11 +-
.../kubernetes/KubernetesRuntimeFactory.java | 3 +
.../kubernetes/KubernetesRuntimeFactoryConfig.java | 6 ++
site2/docs/functions-runtime.md | 4 +
....java => GetTopicsOfNamespaceWithAuthTest.java} | 114 ++++++++++-----------
.../pulsar/tests/integration/cli/CLITest.java | 2 +-
32 files changed, 329 insertions(+), 114 deletions(-)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/admin/{PackagesOpsWithAuthTest.java
=> GetTopicsOfNamespaceWithAuthTest.java} (67%)
