Config

28 references to Config

Aspire.Confluent.Kafka (12)

AspireKafkaConsumerExtensions.cs (7)

189? new(serviceProvider.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(), settings.Config) 191settings.Config); 198InstrumentedConsumerBuilder<TKey, TValue> builder = new(settings.Config); 250configSection.GetSection(nameof(KafkaConsumerSettings.Config)).Bind(settings.Config); 251namedConfigSection.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)

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

OtelTracesTests.cs (6)

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

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;