1 reference to StartReceiveActivity
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
327
using Activity? activity = this.
StartReceiveActivity
(propagationContext, startTime, consumeResult.TopicPartitionOffset, consumeResult.Key);