| # 创建主题 |
| |
| ## 背景 |
| |
| RocketMQ 5.0 引入了 `TopicMessageType` 的概念,并且使用了现有的主题属性功能来实现它。 |
| |
| 主题的创建是通过 `mqadmin` 工具来申明 `message.type` 属性。 |
| |
| ## 使用案例 |
| |
| ```shell |
| # default |
| sh ./mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c DefaultCluster |
| |
| # normal topic |
| sh ./mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c DefaultCluster -a +message.type=NORMAL |
| |
| # fifo topic |
| sh ./mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c DefaultCluster -a +message.type=FIFO |
| |
| # delay topic |
| sh ./mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c DefaultCluster -a +message.type=DELAY |
| |
| # transaction topic |
| sh ./mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c DefaultCluster -a +message.type=TRANSACTION |
| ``` |