9 references to AddKafkaConsumer
Aspire.Confluent.Kafka.Tests (7)
ConfluentKafkaPublicApiTests.cs (2)
30
1 => () => builder.
AddKafkaConsumer
<string, string>(connectionName, configureSettings),
66
1 => () => builder.
AddKafkaConsumer
<string, string>(connectionName, configureSettings),
ConsumerConfigurationTests.cs (2)
67
builder.
AddKafkaConsumer
<string, string>("messaging", configureSettings: SetConnectionString);
148
(false, true, false, false) => () => builder.
AddKafkaConsumer
<string, string>("messaging",
ConsumerConformanceTests.cs (1)
39
builder.
AddKafkaConsumer
<string, string>("messaging", configure);
OtelMetricsTests.cs (1)
53
builder.
AddKafkaConsumer
<string, string>("messaging", configureSettings: settings =>
OtelTracesTests.cs (1)
55
builder.
AddKafkaConsumer
<string, string>("messaging", configureSettings: settings =>
Aspire.Hosting.Kafka.Tests (2)
KafkaFunctionalTests.cs (2)
77
hb.
AddKafkaConsumer
<string, string>("kafka", consumerBuilder =>
222
hb.
AddKafkaConsumer
<string, string>("kafka", consumerBuilder =>