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