5 references to AddKeyedKafkaConsumer
Aspire.Confluent.Kafka.Tests (5)
ConsumerConfigurationTests.cs (2)
63
builder.
AddKeyedKafkaConsumer
<string, string>("messaging", configureSettings: SetConnectionString);
146
(true, true, false, false) => () => builder.
AddKeyedKafkaConsumer
<string, string>("messaging",
ConsumerConformanceTests.cs (1)
43
builder.
AddKeyedKafkaConsumer
<string, string>(key, configure);
OtelMetricsTests.cs (1)
43
builder.
AddKeyedKafkaConsumer
<string, string>("messaging", configureSettings: settings =>
OtelTracesTests.cs (1)
45
builder.
AddKeyedKafkaConsumer
<string, string>("messaging", configureSettings: settings =>