Config

28 references to Config

Aspire.Confluent.Kafka (12)

AspireKafkaConsumerExtensions.cs (7)

196? new(serviceProvider.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(), settings.Config) 198settings.Config); 205InstrumentedConsumerBuilder<TKey, TValue> builder = new(settings.Config); 257configSection.GetSection(nameof(KafkaConsumerSettings.Config)).Bind(settings.Config); 258namedConfigSection.GetSection(nameof(KafkaConsumerSettings.Config)).Bind(settings.Config);

KafkaConsumerSettings.cs (5)

50Debug.Assert(Config is not null); 54Config.BootstrapServers = ConnectionString; 59Config.StatisticsIntervalMs ??= 1000; 65if (Config.BootstrapServers is null) 70if (Config.GroupId is null)

Aspire.Confluent.Kafka.Tests (12)

OtelMetricsTests.cs (6)

44settings.Config.GroupId = "unused"; 45settings.Config.EnablePartitionEof = true; 46settings.Config.AutoOffsetReset = AutoOffsetReset.Earliest; 54settings.Config.GroupId = "unused"; 55settings.Config.EnablePartitionEof = true; 56settings.Config.AutoOffsetReset = AutoOffsetReset.Earliest;

OtelTracesTests.cs (6)

46settings.Config.GroupId = "unused"; 47settings.Config.EnablePartitionEof = true; 48settings.Config.AutoOffsetReset = AutoOffsetReset.Earliest; 56settings.Config.GroupId = "unused"; 57settings.Config.EnablePartitionEof = true; 58settings.Config.AutoOffsetReset = AutoOffsetReset.Earliest;

Aspire.Hosting.Kafka.Tests (4)

KafkaFunctionalTests.cs (4)

78consumerBuilder.Config.GroupId = "aspire-consumer-group"; 79consumerBuilder.Config.AutoOffsetReset = AutoOffsetReset.Earliest; 220consumerBuilder.Config.GroupId = "aspire-consumer-group"; 221consumerBuilder.Config.AutoOffsetReset = AutoOffsetReset.Earliest;