AspireKafkaProducerExtensions Class

Definition

Extension methods for connecting to a Kafka broker.

public static class AspireKafkaProducerExtensions
type AspireKafkaProducerExtensions = class
Public Module AspireKafkaProducerExtensions
Inheritance
AspireKafkaProducerExtensions

Methods

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

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

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

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

Applies to