2 references to CreateConsumerConnectionFactory
Aspire.Confluent.Kafka (2)
AspireKafkaConsumerExtensions.cs (2)
119
builder.Services.AddSingleton<ConsumerConnectionFactory<TKey, TValue>>(sp =>
CreateConsumerConnectionFactory
<TKey, TValue>(sp, settings));
125
builder.Services.AddKeyedSingleton<ConsumerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) =>
CreateConsumerConnectionFactory
<TKey, TValue>(sp, settings, key as string));