2 references to AttributeMessagingKafkaMessageOffset
Aspire.Confluent.Kafka (2)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
367
activity.SetTag(SemanticConventions.
AttributeMessagingKafkaMessageOffset
, topicPartitionOffset?.Offset.Value);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
165
activity.SetTag(SemanticConventions.
AttributeMessagingKafkaMessageOffset
, topicPartitionOffset?.Offset.Value);