1 instantiation of InstrumentedConsumer
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)
46
var consumer = new
InstrumentedConsumer
<TKey, TValue>(base.Build(), this.options);
2 references to InstrumentedConsumer
Aspire.Confluent.Kafka (2)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)
46
var
consumer = new InstrumentedConsumer<TKey, TValue>(base.Build(), this.options);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
87
if (consumer is not
InstrumentedConsumer
<TKey, TValue> instrumentedConsumer)