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