1 instantiation of ConfluentKafkaConsumerInstrumentationOptions
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)
15
private readonly ConfluentKafkaConsumerInstrumentationOptions<TKey, TValue> options =
new
();
3 references to ConfluentKafkaConsumerInstrumentationOptions
Aspire.Confluent.Kafka (3)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (2)
14
private readonly
ConfluentKafkaConsumerInstrumentationOptions
<TKey, TValue> options;
16
public InstrumentedConsumer(IConsumer<TKey, TValue> consumer,
ConfluentKafkaConsumerInstrumentationOptions
<TKey, TValue> options)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)
15
private readonly
ConfluentKafkaConsumerInstrumentationOptions
<TKey, TValue> options = new();