2 references to CreateConsumerBuilder
Aspire.Confluent.Kafka (2)
AspireKafkaConsumerExtensions.cs (2)
118
builder.Services.AddSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(sp =>
CreateConsumerBuilder
(sp, configureBuilder, settings));
124
builder.Services.AddKeyedSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(serviceKey, (sp, key) =>
CreateConsumerBuilder
(sp, configureBuilder, settings));