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