[GitHub] [rocketmq] wwj-radish added a comment to the discussion: controller通知broker变更

[via GitHub]

GitHub user wwj-radish added a comment to the discussion: controller通知broker变更

从日志上看，两个broker都进入了一次这个方法
```java
public void changeToMaster(final int newMasterEpoch, final int 
syncStateSetEpoch, final Set<Long> syncStateSet)
``` 

之后日志也不打印了，可能是因为有这个限制把
```java
    public void changeToMaster(final int newMasterEpoch, final int 
syncStateSetEpoch, final Set<Long> syncStateSet) {
        synchronized (this) {
            if (newMasterEpoch > this.masterEpoch) {
                ...
         }
    }

      public void changeToSlave(final String newMasterAddress, final int 
newMasterEpoch, Long newMasterBrokerId) {
        synchronized (this) {
            if (newMasterEpoch > this.masterEpoch) {
               ...
        }
     }
``` 

然后因为controller主动通知变更角色失败了，两个broker就一直是master了...

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

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