AttributeMessagingKafkaMessageKey

3 references to AttributeMessagingKafkaMessageKey

Aspire.Confluent.Kafka (3)

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

372activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);

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

348activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, message.Key);

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

170activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);