RocketMQ这个怎么解决啊？
RocketMQ这个怎么解决啊？
2主2从 2nameserver 3controller 现在断掉一个主无法切换 其中断掉的主broker报错为：2024-08-19 19:28:09 ERROR FlowMonitor - Interrupted
java.lang.InterruptedException: null
at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081)
at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1369)
at org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114)
at org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117)
at org.apache.rocketmq.store.ha.FlowMonitor.run(FlowMonitor.java:37)
at java.base/java.lang.Thread.run(Thread.java:829)
写回答
-
用getSyncStateSet命令看下broker状态。此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
2024-08-28 10:42:45赞同 19 展开评论 打赏 -
北京阿里云ACE会长确认所有Broker（包括Master和Slave）都正确配置了Name Server地址，并且所有Broker都已成功注册到Name Server上。Master Broker与对应的Slave Broker之间的数据同步配置也需要检查，确保复制功能正常运作
Name Server作为服务发现的核心组件，需要确认所有Name Server实例都在运行并且网络可达。
2024-08-28 09:23:54赞同 16 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系，全系产品 Serverless 化。RocketMQ 一站式学习：https://rocketmq.io/
