fix issue-35
@@ -1103,7 +1103,9 @@ public class ClusterManager extends Service {
TopicConfig topicConfig = buildTopicConfigCache(((PartitionGroupEvent) event.getMetaEvent()).getTopic());
PartitionGroup groupNew = topicConfig.fetchPartitionGroupByGroup(((PartitionGroupEvent) event.getMetaEvent()).getPartitionGroup());
Set<Integer> brokerIds = new HashSet<>();
+ if (groupOld != null)
brokerIds.addAll(groupOld.getReplicas());
+ if (groupNew != null)
brokerIds.addAll(groupNew.getReplicas());
if(!brokerIds.contains(brokerConfig.getBrokerId())){
return;
