1 instantiation of KafkaProducerSettings
Aspire.Confluent.Kafka (1)
AspireKafkaProducerExtensions.cs (1)
253KafkaProducerSettings settings = new();
38 references to KafkaProducerSettings
Aspire.Confluent.Kafka (27)
AspireKafkaProducerExtensions.cs (27)
25/// <inheritdoc cref="AddKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 29/// <inheritdoc cref="AddKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 30public static void AddKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings) 33/// <inheritdoc cref="AddKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 37/// <inheritdoc cref="AddKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 41/// <inheritdoc cref="AddKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 42public static void AddKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) 50/// <param name="configureSettings">An optional method used for customizing the <see cref="KafkaProducerSettings"/>.</param> 53public static void AddKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) 56/// <inheritdoc cref="AddKeyedKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 64/// <inheritdoc cref="AddKeyedKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 65public static void AddKeyedKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings) 72/// <inheritdoc cref="AddKeyedKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 80/// <inheritdoc cref="AddKeyedKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 88/// <inheritdoc cref="AddKeyedKafkaProducer{TKey, TValue}(IHostApplicationBuilder, string, Action{KafkaProducerSettings}?, Action{IServiceProvider, ProducerBuilder{TKey, TValue}}?)"/> 89public static void AddKeyedKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) 101/// <param name="configureSettings">An optional method used for customizing the <see cref="KafkaProducerSettings"/>.</param> 104public static void AddKeyedKafkaProducer<TKey, TValue>(this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) 113Action<KafkaProducerSettings>? configureSettings, 121var settings = BuildProducerSettings(builder, configureSettings, connectionName); 193IServiceProvider serviceProvider, KafkaProducerSettings settings, string? key = null) 201private static InstrumentedProducerBuilder<TKey, TValue> CreateProducerBuilder<TKey, TValue>(IServiceProvider serviceProvider, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder, KafkaProducerSettings settings) 249private static KafkaProducerSettings BuildProducerSettings(IHostApplicationBuilder builder, Action<KafkaProducerSettings>? configureSettings, string connectionName) 253KafkaProducerSettings settings = new(); 258configSection.GetSection(nameof(KafkaProducerSettings.Config)).Bind(settings.Config); 259namedConfigSection.GetSection(nameof(KafkaProducerSettings.Config)).Bind(settings.Config);
Aspire.Confluent.Kafka.Tests (11)
ConfluentKafkaPublicApiTests.cs (4)
159Action<KafkaProducerSettings>? configureSettings = null; 195Action<KafkaProducerSettings>? configureSettings = null; 227Action<KafkaProducerSettings>? configureSettings = null; 263Action<KafkaProducerSettings>? configureSettings = null;
ProducerConfigurationTests.cs (2)
54static void SetConnectionString(KafkaProducerSettings settings) => settings.ConnectionString = CommonHelpers.TestingEndpoint; 203void ConfigureSettings(KafkaProducerSettings _)
ProducerConformanceTests.cs (5)
13public class ProducerConformanceTests : ConformanceTests<IProducer<string, string>, KafkaProducerSettings> 34protected override void RegisterComponent(HostApplicationBuilder builder, Action<KafkaProducerSettings>? configure = null, string? key = null) 46protected override void SetHealthCheck(KafkaProducerSettings options, bool enabled) => options.DisableHealthChecks = !enabled; 48protected override void SetMetrics(KafkaProducerSettings options, bool enabled) => options.DisableMetrics = !enabled; 50protected override void SetTracing(KafkaProducerSettings options, bool enabled)