9 references to AddKeyedKafkaConsumer
Aspire.Confluent.Kafka.Tests (9)
Aspire8MetricsTests.cs (2)
33
builder.
AddKeyedKafkaConsumer
<string, string>("messaging");
148
builder.
AddKeyedKafkaConsumer
<string, string>("messaging");
ConfluentKafkaPublicApiTests.cs (2)
97
0 => () => builder.
AddKeyedKafkaConsumer
<string, string>(name),
133
0 => () => builder.
AddKeyedKafkaConsumer
<string, string>(name),
ConsumerConfigurationTests.cs (3)
30
builder.
AddKeyedKafkaConsumer
<string, string>("messaging");
96
builder.
AddKeyedKafkaConsumer
<string, string>("messaging");
142
(true, false, false, false) => () => builder.
AddKeyedKafkaConsumer
<string, string>("messaging"),
ConsumerConformanceTests.cs (2)
104
builder.
AddKeyedKafkaConsumer
<string, string>("messaging2");
105
builder.
AddKeyedKafkaConsumer
<string, string>("messaging3");