Franz.Common.Messaging.MassTransit 3.0.0

dotnet add package Franz.Common.Messaging.MassTransit --version 3.0.0
                    
NuGet\Install-Package Franz.Common.Messaging.MassTransit -Version 3.0.0
                    
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Franz.Common.Messaging.MassTransit" Version="3.0.0" />
                    
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Franz.Common.Messaging.MassTransit" Version="3.0.0" />
                    
Directory.Packages.props
<PackageReference Include="Franz.Common.Messaging.MassTransit" />
                    
Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add Franz.Common.Messaging.MassTransit --version 3.0.0
                    
#r "nuget: Franz.Common.Messaging.MassTransit, 3.0.0"
                    
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#:package Franz.Common.Messaging.MassTransit@3.0.0
                    
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=Franz.Common.Messaging.MassTransit&version=3.0.0
                    
Install as a Cake Addin
#tool nuget:?package=Franz.Common.Messaging.MassTransit&version=3.0.0
                    
Install as a Cake Tool

Franz.Common.Messaging.MassTransit

Minimal MassTransit Kafka rider and Confluent producer/consumer adapters.

Overview

This package currently provides a registration helper for a MassTransit in-memory bus plus Kafka rider, a Confluent Kafka producer adapter, and a separate Confluent consumer implementation. It is not the same integration path as Franz.Common.Messaging.Kafka.

Installation

dotnet add package Franz.Common.Messaging.MassTransit

MassTransit rider registration

using MassTransit;

builder.Services.AddMassTransitKafkaServices(
    kafkaBootstrapServers: "localhost:9092",
    configureConsumers: rider =>
    {
        rider.AddConsumer<OrdersConsumer>();
    });

The helper configures an in-memory MassTransit bus, registers a Kafka rider, invokes the supplied rider-registration callback, and registers a singleton Confluent IProducer<string, string> plus scoped IKafkaProducer.

The current helper does not expose the Kafka factory-configuration callback needed to declare TopicEndpoint<TConsumer>(...). Registering a consumer type through the callback therefore does not, by itself, establish a Kafka topic subscription. Do not treat this helper as a complete hosted Kafka consumer configuration.

Separate Confluent consumer

The package also exposes KafkaConsumer through IKafkaConsumer. Its constructor requires an IConsumer<string, string> and IServiceScopeFactory. The helper above does not register IKafkaConsumer; applications using this path must register and configure the Confluent consumer explicitly.

The consumer deserializes each payload, creates an async DI scope, optionally establishes validated tenant context when the messaging multi-tenancy initializer is registered, invokes the supplied handler, and commits the consumed record after successful handling.

Production boundary

For a complete Franz Kafka transport with topic provisioning, generated manifest validation, producer/consumer registration, hosted lifecycle, and outbox support, use Franz.Common.Messaging.Kafka with Franz.Common.Messaging.Hosting.Kafka.

License

MIT. See the repository LICENSE.

Product Compatible and additional computed target framework versions.
.NET net10.0 is compatible.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last Updated
3.0.0 77 11/10/2026
2.3.4 338 11/1/2026
2.3.3 104 10/28/2026
2.3.2 108 10/27/2026
2.3.1 103 10/26/2026
2.3.0 211 7/21/2026
2.2.19 127 7/19/2026
2.2.18 140 7/19/2026
2.2.17 135 7/12/2026
2.2.16 146 7/2/2026
2.2.15 149 6/29/2026
2.2.14 133 6/29/2026
2.2.13 141 6/29/2026
2.2.12 135 6/28/2026
2.2.11 130 6/28/2026
2.2.10 133 6/28/2026
2.2.9 144 6/28/2026
2.2.8 135 6/28/2026
2.2.7 139 6/7/2026
2.2.6 144 6/6/2026
Loading failed