Skip to content

主备集群,master宕机后,slave存活。dashboard不显示topic列表。 #391

@zf-ship

Description

@zf-ship

@OverRide
public List examineTopicConfig(String topic) {
List topicConfigInfoList = Lists.newArrayList();
TopicRouteData topicRouteData = route(topic);
for (BrokerData brokerData : topicRouteData.getBrokerDatas()) {
TopicConfigInfo topicConfigInfo = new TopicConfigInfo();
TopicConfig topicConfig = examineTopicConfig(topic, brokerData.getBrokerName());
BeanUtils.copyProperties(topicConfig, topicConfigInfo);// # 这里报错
topicConfigInfo.setBrokerNameList(Lists.newArrayList(brokerData.getBrokerName()));
String messageType = topicConfig.getAttributes().get(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName());
if (StringUtils.isBlank(messageType)) {
messageType = TopicMessageType.UNSPECIFIED.name();
}
topicConfigInfo.setMessageType(messageType);
topicConfigInfoList.add(topicConfigInfo);
}
return topicConfigInfoList;
}
可否这样调整
@OverRide
public List examineTopicConfig(String topic) {
List topicConfigInfoList = Lists.newArrayList();
TopicRouteData topicRouteData = route(topic);
for (BrokerData brokerData : topicRouteData.getBrokerDatas()) {
TopicConfigInfo topicConfigInfo = new TopicConfigInfo();
TopicConfig topicConfig = examineTopicConfig(topic, brokerData.getBrokerName());
topicConfigInfo.setBrokerNameList(Lists.newArrayList(brokerData.getBrokerName()));
if (topicConfig == null) {
log.warn("TopicConfig is null ,topic:{},brokerData:{}",topic,brokerData);
String messageType = TopicMessageType.UNSPECIFIED.name();
topicConfigInfo.setMessageType(messageType);
} else {
BeanUtils.copyProperties(topicConfig, topicConfigInfo);
String messageType = topicConfig.getAttributes().get(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName());
if (StringUtils.isBlank(messageType)) {
messageType = TopicMessageType.UNSPECIFIED.name();
}
topicConfigInfo.setMessageType(messageType);
}

        topicConfigInfoList.add(topicConfigInfo);
    }
    return topicConfigInfoList;
}

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions