10 references to Config
Aspire.Confluent.Kafka (10)
AspireKafkaProducerExtensions.cs (6)
162
=> new(CreateProducerBuilder(serviceProvider, configureBuilder, settings), settings.
Config
);
168
ProducerBuilder<TKey, TValue> builder = new(settings.
Config
);
220
configSection.GetSection(nameof(KafkaProducerSettings.
Config
)).Bind(settings.
Config
);
221
namedConfigSection.GetSection(nameof(KafkaProducerSettings.
Config
)).Bind(settings.
Config
);
KafkaProducerSettings.cs (4)
42
Debug.Assert(
Config
is not null);
46
Config
.BootstrapServers = ConnectionString;
51
Config
.StatisticsIntervalMs ??= 1000;
57
if (string.IsNullOrEmpty(
Config
.BootstrapServers))