11 references to Config
Aspire.Confluent.Kafka (11)
AspireKafkaProducerExtensions.cs (7)
196
? new(serviceProvider.GetRequiredService<InstrumentedProducerBuilder<TKey, TValue>>(), settings.
Config
)
198
settings.
Config
);
205
InstrumentedProducerBuilder<TKey, TValue> builder = new(settings.
Config
);
258
configSection.GetSection(nameof(KafkaProducerSettings.
Config
)).Bind(settings.
Config
);
259
namedConfigSection.GetSection(nameof(KafkaProducerSettings.
Config
)).Bind(settings.
Config
);
KafkaProducerSettings.cs (4)
50
Debug.Assert(
Config
is not null);
54
Config
.BootstrapServers = ConnectionString;
59
Config
.StatisticsIntervalMs ??= 1000;
65
if (string.IsNullOrEmpty(
Config
.BootstrapServers))