RocketMQ

RocketMQ Attributes

This group describes attributes specific to RocketMQ.

Attributes:

Key	Stability	Value Type	Description	Example Values
rocketmq.consumption_model		string	Model of message consumption. This only applies to consumer spans.	clustering; broadcasting (see more)
rocketmq.message.delay_time_level		int	The delay time level for delay message, which determines the message delay time.	3
rocketmq.message.delivery_timestamp		int	The timestamp in milliseconds that the delay message is expected to be delivered to consumer.	1665987217045
rocketmq.message.group		string	It is essential for FIFO message. Messages that belong to the same message group are always processed one by one within the same consumer group.	myMessageGroup
rocketmq.message.keys		string[]	Key(s) of message, another way to mark message besides message ID.	["keyA", "keyB"]
rocketmq.message.tag		string	The secondary classifier of message besides topic.	tagA
rocketmq.message.type		string	Type of message.	normal; fifo; delay (see more)
rocketmq.namespace		string	Namespace of RocketMQ resources, resources in different namespaces are individual.	myNamespace

rocketmq.consumption_model has the following list of well-known values. If one of them applies, then the respective value MUST be used; otherwise, a custom value MAY be used.

Value	Description	Stability
broadcasting	Broadcasting consumption model
clustering	Clustering consumption model

rocketmq.message.type has the following list of well-known values. If one of them applies, then the respective value MUST be used; otherwise, a custom value MAY be used.

Value	Description	Stability
delay	Delay message
fifo	FIFO message
normal	Normal message
transaction	Transaction message