Oliverwqcwrw commented on issue #5538:
URL: https://github.com/apache/rocketmq/issues/5538#issuecomment-1465356593
> ```
> @Override
> public List<TopicConfigInfo> examineTopicConfig(String topic) {
> List<TopicConfigInfo> 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()));
> topicConfigInfoList.add(topicConfigInfo);
> }
> return topicConfigInfoList;
> }
> ```
>
> we are copying topicConfig to TopicConfigInfo so I have added the
messageType to TopicConfigInfo
>
> ```
> /** topicConfig */
> private String topicName;
> private int writeQueueNums;
> private int readQueueNums;
> private int perm;
> private boolean order;
> **private String messageType**;
> ```
>
> @Oliverwqcwrw Do we have to update anything in TopicConfig also in
rocketMq repo ?
<img width="907" alt="image"
src="https://user-images.githubusercontent.com/31796988/224585898-295dfdbf-6197-4d07-8a69-8f9cdcd60757.png">
IMO, We do not need to modify the rocketmq repository
The latest version of topicConfig has attributes. We need to upgrade
rocketmq-common in dashboard
--
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]