Back to Rocketmq

Create Topic

docs/en/Example_CreateTopic.md

latest852 B
Original Source

Create Topic

Background

The TopicMessageType concept is introduced in RocketMQ 5.0, using the existing topic attribute feature to implement it.

The topic is created by mqadmin tool declaring the message.type attribute.

User Example

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