Config

15 references to Config

Aspire.Confluent.Kafka (11)

AspireKafkaConsumerExtensions.cs (6)

159=> new(CreateConsumerBuilder(serviceProvider, configureBuilder, settings), settings.Config); 165ConsumerBuilder<TKey, TValue> builder = new(settings.Config); 217configSection.GetSection(nameof(KafkaConsumerSettings.Config)).Bind(settings.Config); 218namedConfigSection.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;