This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 91e073d1421 [fix][broker] Fix returns wrong webServiceUrl when both
webServicePort and webServicePortTls are set (#21633)
new 5e0b424af2a Revert "[fix][broker] Fix returns wrong webServiceUrl when
both webServicePort and webServicePortTls are set (#21633)"
new 628e79ded04 [fix][broker] Fix PulsarService.getLookupServiceAddress
returns wrong port if TLS is enabled (#21015)
new ba1f8a13956 [fix][broker] Fix returns wrong webServiceUrl when both
webServicePort and webServicePortTls are set (#21633)
new 86206106f07 [fix][broker] Fix returns wrong webServiceUrl when both
webServicePort and webServicePortTls are set (#21842)
new 358d1223d04 [fix][broker] Fix leader broker cannot be determined when
the advertised address and advertised listeners are configured (#21894)
new 89f722fc9b6 [fix][broker] Restore the broker id to match the format
used in existing Pulsar releases (#21937)
The 6 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 | 34 ++-
.../pulsar/broker/admin/impl/BrokersBase.java | 24 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 11 +-
.../pulsar/broker/loadbalance/LeaderBroker.java | 18 ++
.../broker/loadbalance/LeaderElectionService.java | 12 +-
.../pulsar/broker/loadbalance/NoopLoadManager.java | 14 +-
.../pulsar/broker/loadbalance/ResourceUnit.java | 2 -
.../loadbalance/extensions/BrokerRegistryImpl.java | 2 +-
.../extensions/ExtensibleLoadManagerImpl.java | 15 +-
.../channel/ServiceUnitStateChannelImpl.java | 38 +--
.../policies/IsolationPoliciesHelper.java | 8 +-
.../reporter/BrokerLoadDataReporter.java | 14 +-
.../reporter/TopBundleLoadDataReporter.java | 14 +-
.../broker/loadbalance/impl/LoadManagerShared.java | 99 +++----
.../loadbalance/impl/ModularLoadManagerImpl.java | 15 +-
.../impl/ModularLoadManagerWrapper.java | 21 +-
.../loadbalance/impl/SimpleLoadManagerImpl.java | 42 ++-
.../pulsar/broker/namespace/NamespaceService.java | 75 ++---
.../pulsar/broker/service/BrokerService.java | 2 +-
.../service/nonpersistent/NonPersistentTopic.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 2 +-
.../pulsar/broker/web/PulsarWebResource.java | 54 ++--
.../apache/pulsar/broker/PulsarServiceTest.java | 2 +
.../apache/pulsar/broker/SLAMonitoringTest.java | 16 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 21 +-
.../broker/admin/AdminApiMultiBrokersTest.java | 5 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 30 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 7 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 7 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 4 -
...isedListenersMultiBrokerLeaderElectionTest.java | 42 +++
.../loadbalance/AdvertisedListenersTest.java | 2 -
.../AntiAffinityNamespaceGroupTest.java | 4 +-
.../loadbalance/LeaderElectionServiceTest.java | 3 +-
.../broker/loadbalance/LoadBalancerTest.java | 13 +-
.../loadbalance/MultiBrokerLeaderElectionTest.java | 94 +++++--
.../loadbalance/SimpleLoadManagerImplTest.java | 35 +--
.../loadbalance/extensions/BrokerRegistryTest.java | 4 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 48 ++--
.../channel/ServiceUnitStateChannelTest.java | 312 ++++++++++-----------
.../filter/BrokerIsolationPoliciesFilterTest.java | 64 ++---
.../extensions/scheduler/TransferShedderTest.java | 296 +++++++++----------
.../impl/ModularLoadManagerImplTest.java | 139 ++++-----
.../broker/namespace/NamespaceServiceTest.java | 39 ++-
.../OwnerShipForCurrentServerTestBase.java | 2 -
.../broker/service/AdvertisedAddressTest.java | 2 +-
.../pulsar/broker/service/BrokerServiceTest.java | 4 +-
.../broker/service/ClusterMigrationTest.java | 9 +
.../broker/service/InactiveTopicDeleteTest.java | 4 +-
.../pulsar/broker/service/ReplicatorTest.java | 6 +-
.../systopic/PartitionedSystemTopicTest.java | 12 +-
.../broker/testcontext/PulsarTestContext.java | 45 ++-
.../broker/transaction/TransactionTestBase.java | 2 -
.../pulsar/client/api/BrokerServiceLookupTest.java | 17 +-
.../client/api/ClientAuthenticationTlsTest.java | 4 +-
.../apache/pulsar/compaction/CompactionTest.java | 4 +-
.../org/apache/pulsar/client/admin/Brokers.java | 24 +-
.../pulsar/common/policies/data/BrokerInfo.java | 2 +
.../common/policies/data/impl/BrokerInfoImpl.java | 9 +-
.../pulsar/client/admin/internal/BrokersImpl.java | 8 +-
.../pulsar/proxy/server/ProxyRefreshAuthTest.java | 1 +
.../proxy/server/ProxyServiceTlsStarterTest.java | 1 +
.../integration/containers/BrokerContainer.java | 9 +-
.../integration/containers/ProxyContainer.java | 9 +-
.../tests/integration/tls/ClientTlsTest.java | 9 +
.../integration/topologies/PulsarCluster.java | 40 ++-
.../integration/topologies/PulsarClusterSpec.java | 6 +
67 files changed, 1073 insertions(+), 861 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/AdvertisedListenersMultiBrokerLeaderElectionTest.java
