zergduan commented on issue #287: URL: https://github.com/apache/rocketmq-dashboard/issues/287#issuecomment-2795938467
应该和以下代码有关： https://github.com/apache/rocketmq-dashboard/blob/e76185437f6dd80e363cda35868e056c07f490ff/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java#L80 @Override public TopicList fetchAllTopicList(boolean skipSysProcess, boolean skipRetryAndDlq) { try { TopicList allTopics = mqAdminExt.fetchAllTopicList(); TopicList sysTopics = getSystemTopicList(); Set<String> topics = allTopics.getTopicList().stream().map(topic -> { if (!skipSysProcess && sysTopics.getTopicList().contains(topic)) { topic = String.format("%s%s", "%SYS%", topic); } return topic; }).filter(topic -> { if (skipRetryAndDlq) { return !(topic.startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX) || topic.startsWith(MixAll.DLQ_GROUP_TOPIC_PREFIX)); } return true; }).collect(Collectors.toSet()); allTopics.getTopicList().clear(); allTopics.getTopicList().addAll(topics); return allTopics; } catch (Exception e) { Throwables.throwIfUnchecked(e); throw new RuntimeException(e); } } 看上去 TopicList 取回 Topic 列表后，并没有给所有的主从同步所用的 rmq_sys_SYNC_BROKER_MEMBER_XXX 添加 %SYS% 前缀：  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
