6 references to AddKeyedKafkaConsumer
Aspire.Confluent.Kafka (5)
AspireKafkaConsumerExtensions.cs (5)
54
/// <inheritdoc cref="
AddKeyedKafkaConsumer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaConsumerSettings}?, Action{IServiceProvider, ConsumerBuilder{TKey, TValue}}?)"/>
61
/// <inheritdoc cref="
AddKeyedKafkaConsumer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaConsumerSettings}?, Action{IServiceProvider, ConsumerBuilder{TKey, TValue}}?)"/>
68
/// <inheritdoc cref="
AddKeyedKafkaConsumer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaConsumerSettings}?, Action{IServiceProvider, ConsumerBuilder{TKey, TValue}}?)"/>
75
/// <inheritdoc cref="
AddKeyedKafkaConsumer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaConsumerSettings}?, Action{IServiceProvider, ConsumerBuilder{TKey, TValue}}?)"/>
82
/// <inheritdoc cref="
AddKeyedKafkaConsumer
{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaConsumerSettings}?, Action{IServiceProvider, ConsumerBuilder{TKey, TValue}}?)"/>
Aspire.Confluent.Kafka.Tests (1)
ConsumerConfigurationTests.cs (1)
170
(true, true, false, true) => () => builder.
AddKeyedKafkaConsumer
<string, string>("messaging",