[pulsar] branch master updated (8042512 -> 89841aa)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 8042512  Fixed ProxyConnection to check for existence of auth_data field (#12057)
     add 89841aa  Refactored PulsarResources to avoid building metadata paths everywhere (#11693)

No new revisions were added by this update.

Summary of changes:
 .../authorization/PulsarAuthorizationProvider.java |  35 ++-
 .../pulsar/broker/resources/BaseResources.java     |  78 +++++--
 ...{ClusterResources.java => BrokerResources.java} |  26 +--
 .../pulsar/broker/resources/ClusterResources.java  |  93 +++++++-
 .../resources/DynamicConfigurationResources.java   |  30 +++
 .../broker/resources/LocalPoliciesResources.java   |  28 +++
 .../broker/resources/NamespaceResources.java       | 154 +++++++++++--
 .../broker/resources/ResourceGroupResources.java   |  55 +++++
 .../pulsar/broker/resources/TenantResources.java   | 150 +++++++++++++
 .../pulsar/broker/resources/TopicResources.java    |  61 +++++-
 .../apache/pulsar/PulsarClusterMetadataSetup.java  |  27 ++-
 .../org/apache/pulsar/broker/PulsarService.java    |  11 +-
 .../apache/pulsar/broker/admin/AdminResource.java  |  87 +++-----
 .../apache/pulsar/broker/admin/ZkAdminPaths.java   |  47 ----
 .../pulsar/broker/admin/impl/BrokersBase.java      |  19 +-
 .../pulsar/broker/admin/impl/ClustersBase.java     | 111 +++-------
 .../pulsar/broker/admin/impl/NamespacesBase.java   | 243 ++++++++-------------
 .../broker/admin/impl/PersistentTopicsBase.java    | 125 +++++------
 .../broker/admin/impl/ResourceGroupsBase.java      |  37 +---
 .../pulsar/broker/admin/impl/TenantsBase.java      |  45 ++--
 .../apache/pulsar/broker/admin/v1/Namespaces.java  |  15 +-
 .../broker/admin/v2/NonPersistentTopics.java       |   7 +-
 .../pulsar/broker/namespace/NamespaceService.java  |  42 ++--
 .../resourcegroup/ResourceGroupConfigListener.java |  22 +-
 .../ResourceGroupNamespaceConfigListener.java      |  56 ++---
 .../broker/resourcegroup/ResourceGroupService.java |  35 +--
 .../pulsar/broker/service/AbstractReplicator.java  |  10 +-
 .../pulsar/broker/service/BacklogQuotaManager.java |  26 +--
 .../pulsar/broker/service/BrokerService.java       | 113 +++++-----
 .../service/nonpersistent/NonPersistentTopic.java  |  10 +-
 .../service/persistent/MessageDeduplication.java   |  11 +-
 .../broker/service/persistent/PersistentTopic.java |  37 ++--
 .../pulsar/broker/web/PulsarWebResource.java       | 181 ++-------------
 .../apache/pulsar/broker/admin/AdminApiTest.java   |   9 +-
 .../pulsar/broker/admin/v1/V1_AdminApiTest.java    |   4 +-
 .../broker/loadbalance/LoadBalancerTest.java       |  14 +-
 .../loadbalance/SimpleLoadManagerImplTest.java     |   6 +-
 .../RGUsageMTAggrWaitForAllMesgsTest.java          | 161 +++++++-------
 .../ResourceGroupConfigListenerTest.java           |  21 +-
 .../ResourceGroupRateLimiterTest.java              |   4 +-
 .../resourcegroup/ResourceGroupServiceTest.java    |  10 +-
 .../ResourceGroupUsageAggregationTest.java         |   7 +-
 .../BacklogQuotaManagerConfigurationTest.java      |   2 +
 .../service/BrokerServiceThrottlingTest.java       |  16 +-
 .../PersistentDispatcherFailoverConsumerTest.java  |   4 +
 .../pulsar/broker/service/PersistentTopicTest.java |  33 +--
 .../service/ReplicatorRemoveClusterTest.java       | 110 ++++++++++
 .../pulsar/broker/service/ReplicatorTest.java      |  49 -----
 .../pulsar/broker/service/ServerCnxTest.java       |   6 +-
 .../persistent/PersistentSubscriptionTest.java     |   2 +
 .../apache/pulsar/broker/web/WebServiceTest.java   |   3 +-
 .../broker/zookeeper/ClusterMetadataSetupTest.java |  25 +--
 .../pulsar/client/api/PartitionCreationTest.java   |   5 +-
 .../client/impl/BrokerClientIntegrationTest.java   |  14 +-
 .../discovery/service/BrokerDiscoveryProvider.java |  19 +-
 .../functions/worker/PulsarWorkerService.java      |  17 +-
 .../metadata/api/MetadataStoreException.java       |   4 +
 .../metadata/cache/impl/MetadataCacheImpl.java     |   3 +-
 .../proxy/server/BrokerDiscoveryProvider.java      |  24 +-
 .../apache/pulsar/websocket/WebSocketService.java  |   5 +-
 60 files changed, 1378 insertions(+), 1226 deletions(-)
 copy pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/{ClusterResources.java => BrokerResources.java} (58%)
 delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/ZkAdminPaths.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java