search

dyrnq / springcloud-rocketmq-example

POC new features of rocketmq5
https://github.com/apache/rocketmq
0 stars 0 forks source link

DELAY message test #13

Open dyrnq opened 1 month ago

dyrnq commented 1 month ago 

root@f29fae7aa904:/opt/rocketmq/bin# ./mqadmin updateTopic -c DefaultCluster -t demo -n n1:9876 -a +message.type=DELAY

root@f29fae7aa904:/opt/rocketmq/bin# ./mqadmin exportMetaData  -c DefaultCluster -t demo -n n1:9876
export /tmp/rocketmq/export/topic.json success

root@f29fae7aa904:/opt/rocketmq/bin# cat /tmp/rocketmq/export/topic.json
{
        "exportTime":1729052700277,
        "topicConfigTable":{
                "demo":{
                        "attributes":{
                                "message.type":"DELAY"
                        },
                        "order":false,
                        "perm":6,
                        "readQueueNums":16,
                        "topicFilterType":"SINGLE_TAG",
                        "topicName":"demo",
                        "topicSysFlag":0,
                        "writeQueueNums":16
                },
                "DefaultHeartBeatSyncerTopic":{
                        "attributes":{},
                        "order":false,
                        "perm":6,
                        "readQueueNums":2,
                        "topicFilterType":"SINGLE_TAG",
                        "topicName":"DefaultHeartBeatSyncerTopic",
                        "topicSysFlag":0,
                        "writeQueueNums":2
                }
        }
}root@f29fae7aa904:/opt/rocketmq/bin#
dyrnq commented 1 month ago

https://github.com/alibaba/spring-cloud-alibaba/issues/3829