CreateConsumerConnectionFactory

2 references to CreateConsumerConnectionFactory

Aspire.Confluent.Kafka (2)

AspireKafkaConsumerExtensions.cs (2)

116builder.Services.AddSingleton<ConsumerConnectionFactory<TKey, TValue>>(sp => CreateConsumerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings)); 121builder.Services.AddKeyedSingleton<ConsumerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings));