Share via

AspireKafkaConsumerExtensions Class

  • Reference

Definition

Namespace:
Microsoft.Extensions.Hosting
Assembly:
Aspire.Confluent.Kafka.dll
Package:
Aspire.Confluent.Kafka v8.0.0
Package:
Aspire.Confluent.Kafka v8.0.1
Source:
AspireKafkaConsumerExtensions.cs
Source:
AspireKafkaConsumerExtensions.cs

Extension methods for connecting to a Kafka broker.

public static class AspireKafkaConsumerExtensions
type AspireKafkaConsumerExtensions = class
Public Module AspireKafkaConsumerExtensions
Inheritance
Object
AspireKafkaConsumerExtensions

Methods

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

Registers Confluent.Kafka.IConsumer`2 as a singleton in the services provided by the builder.
AddKeyedKafkaConsumer<TKey,TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey,TValue>>)

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

Applies to