How to view the message.type attribute of a Topic？

[kutouziUk]

The FIFO attribute was specified when the Topic was created

The attribute is not displayed in the query result
sh bin/mqadmin topicRoute -b localhost:9016 -n localhost:9015 -t TTLK

and dashboard can't query this information either

[zhouxinyu]

Good catch, the related tools are incomplete, feel free to assign this issue to yourself if you want.

[The-Gamer-01]

I would like to give it a try, can you assign this issue to me

[Oliverwqcwrw]

I would like to give it a try, can you assign this issue to me

done

[Abhijeetmishr]

@Oliverwqcwrw @zhouxinyu Can I pick this up ?

[Oliverwqcwrw]

Hi @The-Gamer-01 , Since you haven't submitted PR for a long time, I'm going to assign this task to @Abhijeetmishr . You are also welcome to revise other issues, And welcome to the community @Abhijeetmishr

[Abhijeetmishr]

Hi @The-Gamer-01 , Since you haven't submitted PR for a long time, I'm going to assign this task to @Abhijeetmishr . You are also welcome to revise other issues, And welcome to the community @Abhijeetmishr

@Oliverwqcwrw Thank you Oliver, Will definitely check other issues also which needs update.
Regards

[Abhijeetmishr]

@zhouxinyu @kutouziUk @Oliverwqcwrw I think QueueData Class doesnot have this field (message.type)
.
Correct me if I'm going in wrong direction.
Regards

[Oliverwqcwrw]

@zhouxinyu @kutouziUk @Oliverwqcwrw I think QueueData Class doesnot have this field (message.type) . Correct me if I'm going in wrong direction. Regards

Please take a look at the TopicConfig query interface, add a messageType to the return value and display it on the page

The dashboard repository is here rocketmq-dashboard

Example_CreateTopic.md

[Abhijeetmishr]

@zhouxinyu @kutouziUk @Oliverwqcwrw I think QueueData Class doesnot have this field (message.type) . Correct me if I'm going in wrong direction. Regards

Please take a look at the TopicConfig query interface, add a messageType to the return value and display it on the page
The dashboard repository is here rocketmq-dashboard

Example_CreateTopic.md

@Oliverwqcwrw as far as my understanding change is required in both the places:-

1. in the query result
2. on the dashboard as well

[Abhijeetmishr]

@Oliverwqcwrw @zhouxinyu The attribute is not displayed in the query result

can anyone point out which controller is responsible for this ?

[Oliverwqcwrw]

@Oliverwqcwrw @zhouxinyu The attribute is not displayed in the query result can anyone point out which controller is responsible for this ?

You can find it int the topics.json

[Abhijeetmishr]

 @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 ?

[Oliverwqcwrw]

 @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 ?

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

[Abhijeetmishr]

@Oliverwqcwrw I have raised a PR for this in rocketmq-dashboard but I am getting some build error that I have a fix and I have reported link but none has responded yet.
Is there any forum and chat group where I can get response faster for any issue related to Apache community?

[Oliverwqcwrw]

@Oliverwqcwrw I have raised a PR for this in rocketmq-dashboard but I am getting some build error that I have a fix and I have reported link but none has responded yet. Is there any forum and chat group where I can get response faster for any issue related to Apache community?

Hello @Abhijeetmishr ,
I have assigned the issue to you # 149

[Abhijeetmishr]

@Oliverwqcwrw Please check this when you are available.

[github-actions]

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

[github-actions]

This issue was closed because it has been inactive for 3 days since being marked as stale.