AspireKafkaProducerExtensions
Class static net10.0
Extension methods for connecting to a Kafka broker.
namespace Microsoft.Extensions.Hosting;
public static class AspireKafkaProducerExtensions{ // ...} 12 members
Methods12
Section titled MethodsAddKafkaProducer(IHostApplicationBuilder, string)extensionAddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extensionAddKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extensionAddKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extensionAddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extensionAddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension Registers
Kafka.IProducer`2 as a singleton in the services provided by the builder. AddKeyedKafkaProducer(IHostApplicationBuilder, string)extensionAddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extensionAddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extensionAddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extensionAddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extensionAddKeyedKafkaProducer(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.