mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
836 B
836 B
创建主题
背景
RocketMQ 5.0 引入了 TopicMessageType 的概念,并且使用了现有的主题属性功能来实现它。
主题的创建是通过 mqadmin 工具来申明 message.type 属性。
使用案例
# 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