Emit.Kafka
1.0.0-alpha.19
dotnet add package Emit.Kafka --version 1.0.0-alpha.19
NuGet\Install-Package Emit.Kafka -Version 1.0.0-alpha.19
<PackageReference Include="Emit.Kafka" Version="1.0.0-alpha.19" />
<PackageVersion Include="Emit.Kafka" Version="1.0.0-alpha.19" />
<PackageReference Include="Emit.Kafka" />
paket add Emit.Kafka --version 1.0.0-alpha.19
#r "nuget: Emit.Kafka, 1.0.0-alpha.19"
#:package Emit.Kafka@1.0.0-alpha.19
#addin nuget:?package=Emit.Kafka&version=1.0.0-alpha.19&prerelease
#tool nuget:?package=Emit.Kafka&version=1.0.0-alpha.19&prerelease
Emit.Kafka
Kafka provider for Emit. Connects the outbox pipeline to Kafka so your messages get delivered reliably, in order, exactly once per group — even across restarts, crashes, and the usual distributed systems chaos.
In outbox mode, producers write serialized messages into your database transaction. The background worker handles delivery to Kafka and cleans up on success. In direct mode, messages go straight to Kafka without persistence, for cases where fire-and-forget with some resilience is good enough.
Each producer is configured at registration time with a topic and serializers for both key and value. Sync and async serializers are supported, so Schema Registry-backed formats like Avro, Protobuf, and JSON Schema work out of the box via the companion serializer packages.
| 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
- Confluent.Kafka (>= 2.13.0)
- Confluent.SchemaRegistry (>= 2.13.0)
- Emit (>= 1.0.0-alpha.19)
- Microsoft.Extensions.DependencyInjection (>= 10.0.0)
NuGet packages (4)
Showing the top 4 NuGet packages that depend on Emit.Kafka:
| Package | Downloads |
|---|---|
|
Emit.Kafka.JsonSerializer
JSON Schema serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed JSON serialization. |
|
|
Emit.Kafka.AvroSerializer
Avro serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed Avro serialization. |
|
|
Emit.Kafka.ProtobufSerializer
Protobuf serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed Protobuf serialization. |
|
|
Emit.Kafka.HealthChecks
ASP.NET Core health check for Emit's Kafka provider. Registers a broker connectivity probe that can be wired into Kubernetes liveness and readiness endpoints. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 1.0.0-alpha.19 | 55 | 10/26/2026 |
| 1.0.0-alpha.18 | 88 | 10/21/2026 |
| 1.0.0-alpha.17 | 176 | 9/8/2026 |
| 1.0.0-alpha.16 | 106 | 9/8/2026 |
| 1.0.0-alpha.15 | 238 | 6/30/2026 |
| 1.0.0-alpha.14 | 271 | 5/8/2026 |
| 1.0.0-alpha.13 | 100 | 4/30/2026 |
| 1.0.0-alpha.12 | 89 | 4/29/2026 |
| 1.0.0-alpha.11 | 100 | 4/24/2026 |
| 1.0.0-alpha.10 | 115 | 4/17/2026 |
| 1.0.0-alpha.9 | 106 | 4/11/2026 |
| 1.0.0-alpha.8 | 110 | 3/31/2026 |
| 1.0.0-alpha.7 | 102 | 3/25/2026 |
| 1.0.0-alpha.6 | 96 | 3/13/2026 |
| 1.0.0-alpha.5 | 100 | 3/12/2026 |
| 1.0.0-alpha.4 | 106 | 3/12/2026 |
| 1.0.0-alpha.3 | 87 | 3/6/2026 |
| 1.0.0-alpha.2 | 84 | 3/6/2026 |
| 1.0.0-alpha.1 | 87 | 3/6/2026 |