5 references to KafkaMessagingSystem
Aspire.Confluent.Kafka (5)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (2)
288
ConfluentKafkaCommon.
KafkaMessagingSystem
),
363
activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.
KafkaMessagingSystem
);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (2)
286
ConfluentKafkaCommon.
KafkaMessagingSystem
),
341
activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.
KafkaMessagingSystem
);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
161
activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.
KafkaMessagingSystem
);