diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java index 141e020d7ca45..05c984d0349b7 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java @@ -275,11 +275,11 @@ public void initialize(final PulsarService pulsar) { // if the placement strategy is also a load shedding strategy // we need to check two strategies are the same if (!conf.getLoadBalancerLoadSheddingStrategy().equals( - conf.getLoadBalancerPlacementStrategy())) { + conf.getLoadBalancerLoadPlacementStrategy())) { throw new IllegalArgumentException("The load shedding strategy: " + conf.getLoadBalancerLoadSheddingStrategy() + " can't work with the placement strategy: " - + conf.getLoadBalancerPlacementStrategy()); + + conf.getLoadBalancerLoadPlacementStrategy()); } // bind the load shedding strategy and the placement strategy loadSheddingStrategy = (LoadSheddingStrategy) placementStrategy;