AspireKafkaProducerExtensions Methods
ClassMethods12 members
Extension methods for connecting to a Kafka broker.
AddKafkaProducer(IHostApplicationBuilder, string)Section titled AddKafkaProducer(IHostApplicationBuilder, string)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName) { // ... }}Parameters
builderIHostApplicationBuilderconnectionNamestringAddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)Section titled AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings) { // ... }}Parameters
builderIHostApplicationBuilderconnectionNamestringconfigureSettingsAction<KafkaProducerSettings>AddKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)Section titled AddKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuilderconnectionNamestringconfigureBuilderAction<ProducerBuilder<TKey, TValue>>AddKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)Section titled AddKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuilderconnectionNamestringconfigureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)Section titled AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuilderconnectionNamestringconfigureSettingsAction<KafkaProducerSettings>configureBuilderAction<ProducerBuilder<TKey, TValue>>AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)Section titled AddKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extension Registers
Kafka.IProducer`2 as a singleton in the services provided by the builder. public static class AspireKafkaProducerExtensions{ public static void AddKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string connectionName, Action<KafkaProducerSettings>? configureSettings, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuilderThe Hosting.IHostApplicationBuilder to read config from and add services to.connectionNamestringA name used to retrieve the connection string from the ConnectionStrings configuration section.configureSettingsAction<KafkaProducerSettings>An optional method used for customizing the KafkaProducerSettings.configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>A method used for customizing the Kafka.ProducerBuilder`2.Remarks
Reads the configuration from "Aspire:Kafka:Producer" section.
AddKeyedKafkaProducer(IHostApplicationBuilder, string)Section titled AddKeyedKafkaProducer(IHostApplicationBuilder, string)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name) { // ... }}Parameters
builderIHostApplicationBuildernamestringAddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)Section titled AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings) { // ... }}Parameters
builderIHostApplicationBuildernamestringconfigureSettingsAction<KafkaProducerSettings>AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)Section titled AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuildernamestringconfigureBuilderAction<ProducerBuilder<TKey, TValue>>AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)Section titled AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuildernamestringconfigureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)Section titled AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<ProducerBuilder<TKey, TValue>>)extensionpublic static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings, Action<ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuildernamestringconfigureSettingsAction<KafkaProducerSettings>configureBuilderAction<ProducerBuilder<TKey, TValue>>AddKeyedKafkaProducer(IHostApplicationBuilder, string, Action<KafkaProducerSettings>, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>)Section titled AddKeyedKafkaProducer(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. public static class AspireKafkaProducerExtensions{ public static void AddKeyedKafkaProducer<TKey, TValue>( this IHostApplicationBuilder builder, string name, Action<KafkaProducerSettings>? configureSettings, Action<IServiceProvider, ProducerBuilder<TKey, TValue>>? configureBuilder) { // ... }}Parameters
builderIHostApplicationBuilderThe Hosting.IHostApplicationBuilder to read config from and add services to.namestringThe name of the component, which is used as the ServiceDescriptor.ServiceKey of the service and also to retrieve the connection string from the ConnectionStrings configuration section.configureSettingsAction<KafkaProducerSettings>An optional method used for customizing the KafkaProducerSettings.configureBuilderAction<IServiceProvider, ProducerBuilder<TKey, TValue>>An optional method used for customizing the Kafka.ProducerBuilder`2.Remarks
Reads the configuration from "Aspire:Kafka:Producer:{name}" section.