8 references to AddKeyedKafkaProducer
Aspire.Confluent.Kafka (5)
AspireKafkaProducerExtensions.cs (5)
56
/// <inheritdoc cref="
AddKeyedKafkaProducer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/>
64
/// <inheritdoc cref="
AddKeyedKafkaProducer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/>
72
/// <inheritdoc cref="
AddKeyedKafkaProducer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/>
80
/// <inheritdoc cref="
AddKeyedKafkaProducer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/>
88
/// <inheritdoc cref="
AddKeyedKafkaProducer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/>
Aspire.Confluent.Kafka.Tests (3)
ConfluentKafkaPublicApiTests.cs (2)
238
5 => () => builder.
AddKeyedKafkaProducer
(name, configureSettings, configureBuilderWithServiceProvider),
274
5 => () => builder.
AddKeyedKafkaProducer
(name, configureSettings, configureBuilderWithServiceProvider),
ProducerConfigurationTests.cs (1)
160
(true, true, false, true) => () => builder.
AddKeyedKafkaProducer
<string, string>("messaging",