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