opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #4794] Fix deserialize ElectMasterResponseHeader attribute value of brokerMemberGroup is null (#4796)

Browse Source
This commit is contained in:
mxsm
2022-08-08 17:11:14 +08:00
committed by GitHub
parent 705e717a09
commit ce274265db
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java
+4 -2
View File
@@ -211,8 +211,10 @@ public class ReplicasInfoManager {
response.setNewMasterAddress(candidate);
response.setMasterEpoch(masterEpoch + 1);
response.setSyncStateSetEpoch(syncStateSetEpoch);
response.setBrokerMemberGroup(buildBrokerMemberGroup(brokerName));
BrokerMemberGroup brokerMemberGroup = buildBrokerMemberGroup(brokerName);
if (null != brokerMemberGroup) {
result.setBody(brokerMemberGroup.encode());
}
final ElectMasterEvent event = new ElectMasterEvent(brokerName, candidate);
result.addEvent(event);
return true;