AttributeMessagingDestinationName

5 references to AttributeMessagingDestinationName

Aspire.Confluent.Kafka (5)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (2)

290SemanticConventions.AttributeMessagingDestinationName, 365activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (2)

288SemanticConventions.AttributeMessagingDestinationName, 343activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topic);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)

163activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic);