2 references to new
Aspire.Confluent.Kafka (2)
AspireKafkaConsumerExtensions.cs (2)
196
?
new
(serviceProvider.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(), settings.Config)
197
:
new
(serviceProvider.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(key),