GitHub user RongtongJin added a comment to the discussion: controller通知broker变更

> broker监听端口是10911,然后服务都是正常了,日志都没有报错。但是在controller通知broker变更角色的时候,提示这个错误。可以帮忙看下是什么原因吗?
> 
> `2023-06-07 18:01:44 ERROR ControllerManager_NotifyService_2 - Failed to 
> notify broker 192.168.105.104:10911 that role changed 
> org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 
> failed at 
> org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeOneway(NettyRemotingClient.java:759)
>  at 
> org.apache.rocketmq.controller.ControllerManager.doNotifyBrokerRoleChanged(ControllerManager.java:210)
>  at 
> org.apache.rocketmq.controller.ControllerManager$NotifyService.lambda$notifyBroker$0(ControllerManager.java:302)
>  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>  at java.lang.Thread.run(Thread.java:750)`

看是controller没有连接上broker。这个到不会有太大影响,角色变更会依赖2点来保证:1. controller反向通知broker 
2.broker定时会向controller同步元数据信息。即使1失败了,2仍然会起作用。保证角色变更完成

GitHub link: 
https://github.com/apache/rocketmq/discussions/6869#discussioncomment-6110285

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to