diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java index e3f9d0de9b4..f33ca64089e 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java @@ -931,7 +931,7 @@ private void notifyMinBrokerIdChanged(Map brokerAddrMap, String of RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.NOTIFY_MIN_BROKER_ID_CHANGE, requestHeader); for (String brokerAddr : brokerAddrsNotify) { - this.namesrvController.getRemotingClient().invokeOneway(brokerAddr, request, 300); + this.namesrvController.getRemotingClient().invokeOneway(brokerAddr, request, 3000); } }