AspireKafkaProducerExtensions Methods

1. Docs
2. /Reference
3. /Search C# APIs
4. /Aspire.Confluent.Kafka
5. /AspireKafkaProducerExtensions
6. /Methods

ClassMethods12 members

Extension methods for connecting to a Kafka broker.

AddKafkaProducer(IHostApplicationBuilder, string)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs#L27

Parameters

builderIHostApplicationBuilder

connectionNamestring

AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName,
        Action<KafkaProducerSettings>? configureSettings)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs#L31

Parameters

builderIHostApplicationBuilder

connectionNamestring

configureSettingsAction<KafkaProducerSettings>

AddKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName,
        Action<ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

connectionNamestring

configureBuilderAction<ProducerBuilder<TKey, TValue>>

AddKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName,
        Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

connectionNamestring

configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>

AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName,
        Action<KafkaProducerSettings>? configureSettings,
        Action<ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

connectionNamestring

configureSettingsAction<KafkaProducerSettings>

configureBuilderAction<ProducerBuilder<TKey, TValue>>

AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension

Registers Kafka.IProducer`2 as a singleton in the services provided by the builder.

public static class AspireKafkaProducerExtensions
{
    public static void AddKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string connectionName,
        Action<KafkaProducerSettings>? configureSettings,
        Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilderThe Hosting.IHostApplicationBuilder to read config from and add services to.

connectionNamestringA name used to retrieve the connection string from the ConnectionStrings configuration section.

configureSettingsAction<KafkaProducerSettings>An optional method used for customizing the KafkaProducerSettings.

configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>A method used for customizing the Kafka.ProducerBuilder`2.

Remarks

Reads the configuration from "Aspire:Kafka:Producer" section.

AddKeyedKafkaProducer(IHostApplicationBuilder, string)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs#L59-L62

Parameters

builderIHostApplicationBuilder

namestring

AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name,
        Action<KafkaProducerSettings>? configureSettings)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs#L67-L70

Parameters

builderIHostApplicationBuilder

namestring

configureSettingsAction<KafkaProducerSettings>

AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name,
        Action<ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

namestring

configureBuilderAction<ProducerBuilder<TKey, TValue>>

AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name,
        Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

namestring

configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>

AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extension

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name,
        Action<KafkaProducerSettings>? configureSettings,
        Action<ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilder

namestring

configureSettingsAction<KafkaProducerSettings>

configureBuilderAction<ProducerBuilder<TKey, TValue>>

AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension

Registers Kafka.IProducer`2 as a keyed singleton for the given name in the services provided by the builder.

public static class AspireKafkaProducerExtensions
{
    public static void AddKeyedKafkaProducer<TKey, TValue>(
        this IHostApplicationBuilder builder,
        string name,
        Action<KafkaProducerSettings>? configureSettings,
        Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder)
    {
        // ...
    }
}

AspireKafkaProducerExtensions.cs

Parameters

builderIHostApplicationBuilderThe Hosting.IHostApplicationBuilder to read config from and add services to.

namestringThe name of the component, which is used as the ServiceDescriptor.ServiceKey of the service and also to retrieve the connection string from the ConnectionStrings configuration section.

configureSettingsAction<KafkaProducerSettings>An optional method used for customizing the KafkaProducerSettings.

configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>An optional method used for customizing the Kafka.ProducerBuilder`2.

Remarks

Reads the configuration from "Aspire:Kafka:Producer:{name}" section.