Skip to content

Latest commit

 

History

History
26 lines (17 loc) · 853 Bytes

Example_CreateTopic.md

File metadata and controls

26 lines (17 loc) · 853 Bytes

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

# 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