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
<PackageReference Include="Franz.Common.Messaging.MassTransit" Version="3.0.0" />
<PackageVersion Include="Franz.Common.Messaging.MassTransit" Version="3.0.0" />
<PackageReference Include="Franz.Common.Messaging.MassTransit" />
paket add Franz.Common.Messaging.MassTransit --version 3.0.0
#r "nuget: Franz.Common.Messaging.MassTransit, 3.0.0"
#:package Franz.Common.Messaging.MassTransit@3.0.0
#addin nuget:?package=Franz.Common.Messaging.MassTransit&version=3.0.0
#tool nuget:?package=Franz.Common.Messaging.MassTransit&version=3.0.0
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 | Versions 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. |
-
net10.0
- Franz.Common.Errors (>= 3.0.0)
- Franz.Common.Messaging.MultiTenancy (>= 3.0.0)
- MassTransit (>= 9.1.2)
- MassTransit.Kafka (>= 9.1.2)
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 |