diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index d3485f9f65b..595737adf71 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -1539,6 +1539,10 @@ protected void shutdownBasicService() { if (this.transactionalMessageCheckService != null) { this.transactionalMessageCheckService.shutdown(false); } + + if (this.loadBalanceExecutor != null) { + this.loadBalanceExecutor.shutdown(); + } if (this.endTransactionExecutor != null) { this.endTransactionExecutor.shutdown();