Class KafkaAspireExtensions

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

Extensions to integrate Wolverine Kafka transport with Aspire Kafka configuration.

public static class KafkaAspireExtensions

Inheritance

object ← KafkaAspireExtensions

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 = "Aspire:Confluent:Kafka"

Field Value

string

Methods

ApplyAspireClientConfig(IConfiguration, string, ClientConfig)

Applies Aspire client configuration to Wolverine's client config.

public static void ApplyAspireClientConfig(IConfiguration configuration, string serviceName, ClientConfig clientConfig)

Parameters

configuration IConfiguration

serviceName string

clientConfig ClientConfig

ApplyAspireConsumerConfig(IConfiguration, string, ConsumerConfig)

Applies Aspire consumer configuration to Wolverine's consumer config.

public static void ApplyAspireConsumerConfig(IConfiguration configuration, string serviceName, ConsumerConfig consumerConfig)

Parameters

configuration IConfiguration

serviceName string

consumerConfig ConsumerConfig

ApplyAspireProducerConfig(IConfiguration, string, ProducerConfig)

Applies Aspire producer configuration to Wolverine's producer config.

public static void ApplyAspireProducerConfig(IConfiguration configuration, string serviceName, ProducerConfig producerConfig)

Parameters

configuration IConfiguration

serviceName string

producerConfig ProducerConfig

SetConfigClientId(IConfiguration, string, string)

public static void SetConfigClientId(IConfiguration configuration, string serviceName, string clientId)

Parameters

configuration IConfiguration

serviceName string

clientId string

SetConfigConsumerGroupId(IConfiguration, string, string, string)

public static void SetConfigConsumerGroupId(IConfiguration configuration, string serviceName, string groupPrefix, string environment)

Parameters

configuration IConfiguration

serviceName string

groupPrefix string

environment string