-
Notifications
You must be signed in to change notification settings - Fork 629
Description
@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;
}