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