AspireKafkaConsumerExtensions

1. Docs
2. /Reference
3. /Search C# APIs
4. /Aspire.Confluent.Kafka
5. /AspireKafkaConsumerExtensions

Classstaticnet10.0

📦 Aspire.Confluent.Kafka v13.6.0

Extension methods for connecting to a Kafka broker.

namespace Microsoft.Extensions.Hosting;

public static class AspireKafkaConsumerExtensions
{
    // ...
}

Source

Search members of AspireKafkaConsumerExtensions...

12 members

Clear filtersReset all

Methods12

AddKafkaConsumer(IHostApplicationBuilder, string)extension

AddKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>)extension

AddKafkaConsumer(IHostApplicationBuilder, string, Action<ConsumerBuilder<TKey, TValue>>)extension

AddKafkaConsumer(IHostApplicationBuilder, string, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extension

AddKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)extension

AddKafkaConsumer(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)extension

AddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>)extension

AddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<ConsumerBuilder<TKey, TValue>>)extension

AddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)extension

AddKeyedKafkaConsumer(IHostApplicationBuilder, string, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)extension

AddKeyedKafkaConsumer(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.

View all methods