IHostApplicationBuilder
Configuration- Environment
- Logging
- Metrics
- Properties
- Services
ConfigureContainer<TContainerBuilder>(IServiceProviderFactory<TContainerBuilder>, Action<TContainerBuilder>)
AddAzureBlobClient(IHostApplicationBuilder, String, Action<AzureStorageBlobsSettings>, Action<IAzureClientBuilder<BlobServiceClient, BlobClientOptions>>)- AddAzureCosmosClient(IHostApplicationBuilder, String, Action<MicrosoftAzureCosmosSettings>, Action<CosmosClientOptions>)
- AddAzureEventHubBufferedProducerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsBufferedProducerSettings>, Action<IAzureClientBuilder<EventHubBufferedProducerClient, EventHubBufferedProducerClientOptions>>)
- AddAzureEventHubConsumerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsConsumerSettings>, Action<IAzureClientBuilder<EventHubConsumerClient, EventHubConsumerClientOptions>>)
- AddAzureEventHubProducerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsProducerSettings>, Action<IAzureClientBuilder<EventHubProducerClient, EventHubProducerClientOptions>>)
- AddAzureEventProcessorClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsProcessorSettings>, Action<IAzureClientBuilder<EventProcessorClient, EventProcessorClientOptions>>)
- AddAzureKeyVaultClient(IHostApplicationBuilder, String, Action<AzureSecurityKeyVaultSettings>, Action<IAzureClientBuilder<SecretClient, SecretClientOptions>>)
- AddAzureOpenAIClient(IHostApplicationBuilder, String, Action<AzureOpenAISettings>, Action<IAzureClientBuilder<AzureOpenAIClient, AzureOpenAIClientOptions>>)
- AddAzurePartitionReceiverClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsPartitionReceiverSettings>, Action<IAzureClientBuilder<PartitionReceiver, PartitionReceiverOptions>>)
- AddAzureQueueClient(IHostApplicationBuilder, String, Action<AzureStorageQueuesSettings>, Action<IAzureClientBuilder<QueueServiceClient, QueueClientOptions>>)
- AddAzureSearchClient(IHostApplicationBuilder, String, Action<AzureSearchSettings>, Action<IAzureClientBuilder<SearchIndexClient, SearchClientOptions>>)
- AddAzureServiceBusClient(IHostApplicationBuilder, String, Action<AzureMessagingServiceBusSettings>, Action<IAzureClientBuilder<ServiceBusClient, ServiceBusClientOptions>>)
- AddAzureTableClient(IHostApplicationBuilder, String, Action<AzureDataTablesSettings>, Action<IAzureClientBuilder<TableServiceClient, TableClientOptions>>)
- AddAzureWebPubSubServiceClient(IHostApplicationBuilder, String, Action<AzureMessagingWebPubSubSettings>, Action<IAzureClientBuilder<WebPubSubServiceClient, WebPubSubServiceClientOptions>>)
- AddCosmosDbContext<TContext>(IHostApplicationBuilder, String, String, Action<EntityFrameworkCoreCosmosSettings>, Action<DbContextOptionsBuilder>)
- AddElasticsearchClient(IHostApplicationBuilder, String, Action<ElasticClientsElasticsearchSettings>, Action<ElasticsearchClientSettings>)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<ConsumerBuilder<TKey, TValue>>)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)
- AddKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<ProducerBuilder<TKey, TValue>>)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)
- AddKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)
- AddKeyedAzureBlobClient(IHostApplicationBuilder, String, Action<AzureStorageBlobsSettings>, Action<IAzureClientBuilder<BlobServiceClient, BlobClientOptions>>)
- AddKeyedAzureCosmosClient(IHostApplicationBuilder, String, Action<MicrosoftAzureCosmosSettings>, Action<CosmosClientOptions>)
- AddKeyedAzureEventHubBufferedProducerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsBufferedProducerSettings>, Action<IAzureClientBuilder<EventHubBufferedProducerClient, EventHubBufferedProducerClientOptions>>)
- AddKeyedAzureEventHubConsumerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsConsumerSettings>, Action<IAzureClientBuilder<EventHubConsumerClient, EventHubConsumerClientOptions>>)
- AddKeyedAzureEventHubProducerClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsProducerSettings>, Action<IAzureClientBuilder<EventHubProducerClient, EventHubProducerClientOptions>>)
- AddKeyedAzureEventProcessorClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsProcessorSettings>, Action<IAzureClientBuilder<EventProcessorClient, EventProcessorClientOptions>>)
- AddKeyedAzureKeyVaultClient(IHostApplicationBuilder, String, Action<AzureSecurityKeyVaultSettings>, Action<IAzureClientBuilder<SecretClient, SecretClientOptions>>)
- AddKeyedAzureOpenAIClient(IHostApplicationBuilder, String, Action<AzureOpenAISettings>, Action<IAzureClientBuilder<AzureOpenAIClient, AzureOpenAIClientOptions>>)
- AddKeyedAzurePartitionReceiverClient(IHostApplicationBuilder, String, Action<AzureMessagingEventHubsPartitionReceiverSettings>, Action<IAzureClientBuilder<PartitionReceiver, PartitionReceiverOptions>>)
- AddKeyedAzureQueueClient(IHostApplicationBuilder, String, Action<AzureStorageQueuesSettings>, Action<IAzureClientBuilder<QueueServiceClient, QueueClientOptions>>)
- AddKeyedAzureSearchClient(IHostApplicationBuilder, String, Action<AzureSearchSettings>, Action<IAzureClientBuilder<SearchIndexClient, SearchClientOptions>>)
- AddKeyedAzureServiceBusClient(IHostApplicationBuilder, String, Action<AzureMessagingServiceBusSettings>, Action<IAzureClientBuilder<ServiceBusClient, ServiceBusClientOptions>>)
- AddKeyedAzureTableClient(IHostApplicationBuilder, String, Action<AzureDataTablesSettings>, Action<IAzureClientBuilder<TableServiceClient, TableClientOptions>>)
- AddKeyedAzureWebPubSubServiceClient(IHostApplicationBuilder, String, String, Action<AzureMessagingWebPubSubSettings>, Action<IAzureClientBuilder<WebPubSubServiceClient, WebPubSubServiceClientOptions>>)
- AddKeyedElasticsearchClient(IHostApplicationBuilder, String, Action<ElasticClientsElasticsearchSettings>, Action<ElasticsearchClientSettings>)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<ConsumerBuilder<TKey, TValue>>)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>, Action<ConsumerBuilder<TKey, TValue>>)
- AddKeyedKafkaConsumer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaConsumerSettings>, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<ProducerBuilder<TKey, TValue>>)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)
- AddKeyedKafkaProducer<TKey, TValue>(IHostApplicationBuilder, String, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)
- AddKeyedMilvusClient(IHostApplicationBuilder, String, Action<MilvusClientSettings>)
- AddKeyedMongoDBClient(IHostApplicationBuilder, String, Action<MongoDBSettings>, Action<MongoClientSettings>)
- AddKeyedMySqlDataSource(IHostApplicationBuilder, String, Action<MySqlConnectorSettings>)
- AddKeyedNatsClient(IHostApplicationBuilder, String, Action<NatsClientSettings>, Func<NatsOpts, NatsOpts>)
- AddKeyedNpgsqlDataSource(IHostApplicationBuilder, String, Action<NpgsqlSettings>, Action<NpgsqlDataSourceBuilder>)
- AddKeyedOpenAIClientFromConfiguration(IHostApplicationBuilder, String)
- AddKeyedQdrantClient(IHostApplicationBuilder, String, Action<QdrantClientSettings>)
- AddKeyedRabbitMQClient(IHostApplicationBuilder, String, Action<RabbitMQClientSettings>, Action<ConnectionFactory>)
- AddKeyedRedisClient(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddKeyedRedisDistributedCache(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddKeyedRedisOutputCache(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddKeyedSqlServerClient(IHostApplicationBuilder, String, Action<MicrosoftDataSqlClientSettings>)
- AddMilvusClient(IHostApplicationBuilder, String, Action<MilvusClientSettings>)
- AddMongoDBClient(IHostApplicationBuilder, String, Action<MongoDBSettings>, Action<MongoClientSettings>)
- AddMySqlDataSource(IHostApplicationBuilder, String, Action<MySqlConnectorSettings>)
- AddMySqlDbContext<TContext>(IHostApplicationBuilder, String, Action<PomeloEntityFrameworkCoreMySqlSettings>, Action<DbContextOptionsBuilder>)
- AddNatsClient(IHostApplicationBuilder, String, Action<NatsClientSettings>, Func<NatsOpts, NatsOpts>)
- AddNatsJetStream(IHostApplicationBuilder)
- AddNpgsqlDataSource(IHostApplicationBuilder, String, Action<NpgsqlSettings>, Action<NpgsqlDataSourceBuilder>)
- AddNpgsqlDbContext<TContext>(IHostApplicationBuilder, String, Action<NpgsqlEntityFrameworkCorePostgreSQLSettings>, Action<DbContextOptionsBuilder>)
- AddOpenAIClientFromConfiguration(IHostApplicationBuilder, String)
- AddOracleDatabaseDbContext<TContext>(IHostApplicationBuilder, String, Action<OracleEntityFrameworkCoreSettings>, Action<DbContextOptionsBuilder>)
- AddQdrantClient(IHostApplicationBuilder, String, Action<QdrantClientSettings>)
- AddRabbitMQClient(IHostApplicationBuilder, String, Action<RabbitMQClientSettings>, Action<ConnectionFactory>)
- AddRedisClient(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddRedisDistributedCache(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddRedisOutputCache(IHostApplicationBuilder, String, Action<StackExchangeRedisSettings>, Action<ConfigurationOptions>)
- AddSeqEndpoint(IHostApplicationBuilder, String, Action<SeqSettings>)
- AddSqlServerClient(IHostApplicationBuilder, String, Action<MicrosoftDataSqlClientSettings>)
- AddSqlServerDbContext<TContext>(IHostApplicationBuilder, String, Action<MicrosoftEntityFrameworkCoreSqlServerSettings>, Action<DbContextOptionsBuilder>)
- EnrichCosmosDbContext<TContext>(IHostApplicationBuilder, Action<EntityFrameworkCoreCosmosSettings>)
- EnrichMySqlDbContext<TContext>(IHostApplicationBuilder, Action<PomeloEntityFrameworkCoreMySqlSettings>)
- EnrichNpgsqlDbContext<TContext>(IHostApplicationBuilder, Action<NpgsqlEntityFrameworkCorePostgreSQLSettings>)
- EnrichOracleDatabaseDbContext<TContext>(IHostApplicationBuilder, Action<OracleEntityFrameworkCoreSettings>)
- EnrichSqlServerDbContext<TContext>(IHostApplicationBuilder, Action<MicrosoftEntityFrameworkCoreSqlServerSettings>)
net9.0
namespace Microsoft.Extensions.Hosting
{
public static class AspireKafkaConsumerExtensions
{
public static void AddKafkaConsumer<TKey, TValue>(this IHostApplicationBuilder! builder, string! connectionName, Action<IServiceProvider!, ConsumerBuilder<TKey, TValue>!>? configureBuilder);
}
}
| .NET | 8.09.0 |
|---|---|
Information specific to net9.0 | |
| Assemblies | Aspire.Confluent.Kafka , Version=8.2.2.0, PublicKeyToken=cc7b13ffcd2ddd51 Aspire.Confluent.Kafka , Version=9.1.0.0, PublicKeyToken=cc7b13ffcd2ddd51 |
| Referencing | Your project needs a package reference to |
| Package | Aspire.Confluent.Kafka net8.0 |
| Platform Restrictions | This API is supported on all platforms. |
- Built-in API
- Package-provided API