15 references to Config
Aspire.Confluent.Kafka (11)
AspireKafkaConsumerExtensions.cs (6)
162
=> new(CreateConsumerBuilder(serviceProvider, configureBuilder, settings), settings.
Config
);
168
ConsumerBuilder<TKey, TValue> builder = new(settings.
Config
);
220
configSection.GetSection(nameof(KafkaConsumerSettings.
Config
)).Bind(settings.
Config
);
221
namedConfigSection.GetSection(nameof(KafkaConsumerSettings.
Config
)).Bind(settings.
Config
);
KafkaConsumerSettings.cs (5)
42
Debug.Assert(
Config
is not null);
46
Config
.BootstrapServers = ConnectionString;
51
Config
.StatisticsIntervalMs ??= 1000;
57
if (
Config
.BootstrapServers is null)
62
if (
Config
.GroupId is null)
Aspire.Hosting.Kafka.Tests (4)
KafkaFunctionalTests.cs (4)
81
consumerBuilder.
Config
.GroupId = "aspire-consumer-group";
82
consumerBuilder.
Config
.AutoOffsetReset = AutoOffsetReset.Earliest;
225
consumerBuilder.
Config
.GroupId = "aspire-consumer-group";
226
consumerBuilder.
Config
.AutoOffsetReset = AutoOffsetReset.Earliest;