Add messaging.rocketmq.message_group

CHANGELOG.md

@@ -19,6 +19,9 @@ release.
 
 ### Semantic Conventions
 
+- Add `messaging.rocketmq.message_group` attribute.
+  ([#2881](https://github.com/open-telemetry/opentelemetry-specification/pull/2881))
+
 ### Compatibility
 
 - Specify how Prometheus exporters and receivers handle instrumentation scope.

semantic_conventions/trace/messaging.yaml

@@ -220,6 +220,13 @@ groups:
         brief: >
           The unique identifier for each client.
         examples: 'myhost@8742@s8083jm'
+      - id: message_group
+        type: string
+        requirement_level:
+          conditionally_required: If the message type is FIFO.
+        brief: >
+          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.
+        examples: 'myMessageGroup'
       - id: message_type
         type:
           allow_custom_values: false

specification/trace/semantic_conventions/messaging.md

@@ -301,6 +301,7 @@ Specific attributes for Apache RocketMQ are defined below.
 | `messaging.rocketmq.namespace` | string | Namespace of RocketMQ resources, resources in different namespaces are individual. | `myNamespace` | Required |
 | `messaging.rocketmq.client_group` | string | Name of the RocketMQ producer/consumer group that is handling the message. The client type is identified by the SpanKind. | `myConsumerGroup` | Required |
 | `messaging.rocketmq.client_id` | string | The unique identifier for each client. | `myhost@8742@s8083jm` | Required |
+| `messaging.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` | Conditionally Required: If the message type is FIFO. |
 | `messaging.rocketmq.message_type` | string | Type of message. | `normal` | Recommended |
 | `messaging.rocketmq.message_tag` | string | The secondary classifier of message besides topic. | `tagA` | Recommended |
 | `messaging.rocketmq.message_keys` | string[] | Key(s) of message, another way to mark message besides message id. | `[keyA, keyB]` | Recommended |