AspireKafkaConsumerExtensions
Class static net10.0
Extension methods for connecting to a Kafka broker.
namespace Microsoft.Extensions.Hosting;
public static class AspireKafkaConsumerExtensions{ // ...} 12 members
Methods12
Section titled MethodsAddKafkaConsumer(IHostApplicationBuilder, string)extensionAddKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>)extensionAddKafkaConsumer(IHostApplicationBuilder, string, Action<ConsumerBuilder<TKey, TValue>>)extensionAddKafkaConsumer(IHostApplicationBuilder, string, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extensionAddKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)extensionAddKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extension Registers
Kafka.IConsumer`2 as a singleton in the services provided by the builder. AddKeyedKafkaConsumer(IHostApplicationBuilder, string)extensionAddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>)extensionAddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<ConsumerBuilder<TKey, TValue>>)extensionAddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extensionAddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)extensionAddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extension Registers
Kafka.IConsumer`2 as a keyed singleton for the given name in the services provided by the builder.