Class KafkaSetupExtensions

Namespace: Momentum.Extensions.Messaging.Kafka
Assembly: Momentum.Extensions.Messaging.Kafka.dll

[ExcludeFromCodeCoverage]
public static class KafkaSetupExtensions

Inheritance

object ← KafkaSetupExtensions

Inherited Members

object.GetType(), object.MemberwiseClone(), object.ToString(), object.Equals(object?), object.Equals(object?, object?), object.ReferenceEquals(object?, object?), object.GetHashCode()

Fields

SectionName

public const string SectionName = "Messaging"

Field Value

string

Methods

AddKafkaMessagingExtensions(WebApplicationBuilder, string, Action<KafkaProducerSettings>?, Action<KafkaConsumerSettings>?)

Adds Kafka messaging extensions with full Aspire integration to the WebApplicationBuilder.

public static WebApplicationBuilder AddKafkaMessagingExtensions(this WebApplicationBuilder builder, string serviceName = "Messaging", Action<KafkaProducerSettings>? configureProducerSettings = null, Action<KafkaConsumerSettings>? configureConsumerSettings = null)

Parameters

builder WebApplicationBuilder

The WebApplicationBuilder

serviceName string

The connection name for Kafka configuration

configureProducerSettings Action<KafkaProducerSettings>?

Optional producer settings configuration

configureConsumerSettings Action<KafkaConsumerSettings>?

Optional consumer settings configuration

Returns

WebApplicationBuilder

The WebApplicationBuilder for chaining