2 instantiations of ConsumerConnectionFactory
Aspire.Confluent.Kafka (2)
AspireKafkaConsumerExtensions.cs (2)
196? new(serviceProvider.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(), settings.Config) 197: new(serviceProvider.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(key),
8 references to ConsumerConnectionFactory
Aspire.Confluent.Kafka (8)
AspireKafkaConsumerExtensions.cs (8)
126builder.Services.AddSingleton<ConsumerConnectionFactory<TKey, TValue>>(sp => CreateConsumerConnectionFactory<TKey, TValue>(sp, settings)); 127builder.Services.AddSingleton<IConsumer<TKey, TValue>>(sp => sp.GetRequiredService<ConsumerConnectionFactory<TKey, TValue>>().Create()); 132builder.Services.AddKeyedSingleton<ConsumerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerConnectionFactory<TKey, TValue>(sp, settings, key as string)); 133builder.Services.AddKeyedSingleton<IConsumer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(key).Create()); 173var connectionFactory = serviceKey is null 174? sp.GetRequiredService<ConsumerConnectionFactory<TKey, TValue>>() 175: sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(serviceKey); 192private static ConsumerConnectionFactory<TKey, TValue> CreateConsumerConnectionFactory<TKey, TValue>(