1 reference to new
Aspire.Confluent.Kafka (1)
AspireKafkaConsumerExtensions.cs (1)
162
=>
new
(CreateConsumerBuilder(serviceProvider, configureBuilder, settings), settings.Config);