diff options
Diffstat (limited to 'crates/router')
| -rw-r--r-- | crates/router/src/processor/publish.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/crates/router/src/processor/publish.rs b/crates/router/src/processor/publish.rs index 277b674..3158e4d 100644 --- a/crates/router/src/processor/publish.rs +++ b/crates/router/src/processor/publish.rs @@ -32,11 +32,13 @@ pub(crate) async fn to_rule( propagator.inject_context(&cx, &mut injector::HeaderMap(&mut headers)) }); - let span = info_span!("nats.publish"); + let span = info_span!("nats.publish", "otel.kind" = "producer"); span.set_attribute( attribute::MESSAGING_DESTINATION_SUBSCRIPTION_NAME, subject.to_string(), ); + span.set_attribute(attribute::MESSAGING_SYSTEM, "nats"); + state .services .jetstream |