5 references to AttributeMessagingKafkaDestinationPartition
Aspire.Confluent.Kafka (5)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (2)
298SemanticConventions.AttributeMessagingKafkaDestinationPartition, 366activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (2)
296SemanticConventions.AttributeMessagingKafkaDestinationPartition, 353activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, partition);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
164activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value);