Akka.Streams.Kafka
1.2.2
Prefix Reserved
See the version list below for details.
dotnet add package Akka.Streams.Kafka --version 1.2.2
NuGet\Install-Package Akka.Streams.Kafka -Version 1.2.2
<PackageReference Include="Akka.Streams.Kafka" Version="1.2.2" />
<PackageVersion Include="Akka.Streams.Kafka" Version="1.2.2" />
<PackageReference Include="Akka.Streams.Kafka" />
paket add Akka.Streams.Kafka --version 1.2.2
#r "nuget: Akka.Streams.Kafka, 1.2.2"
#:package Akka.Streams.Kafka@1.2.2
#addin nuget:?package=Akka.Streams.Kafka&version=1.2.2
#tool nuget:?package=Akka.Streams.Kafka&version=1.2.2
Apache Kafka adapter for Akka.NET Streams
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. 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. |
| .NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
| .NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
| .NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
| MonoAndroid | monoandroid was computed. |
| MonoMac | monomac was computed. |
| MonoTouch | monotouch was computed. |
| Tizen | tizen40 was computed. tizen60 was computed. |
| Xamarin.iOS | xamarinios was computed. |
| Xamarin.Mac | xamarinmac was computed. |
| Xamarin.TVOS | xamarintvos was computed. |
| Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Akka.Streams (>= 1.4.45)
- Confluent.Kafka (>= 1.9.3)
NuGet packages (4)
Showing the top 4 NuGet packages that depend on Akka.Streams.Kafka:
| Package | Downloads |
|---|---|
|
AkkaDotModule.Webnori
Package Description |
|
|
Yottadem.Kafka.Producer.Sdk
A lightweight and scalable Kafka Producer SDK for .NET applications developed by Yottadem Tech Solutions. |
|
|
Tributary.Kafka.Consumer
Attribute-driven Kafka consumer runtime for .NET, built on Akka.NET Streams. Write a single class of [ConsumeTopic<TConfig>]-attributed methods and bootstrap with KafkaHost.CreateDefaultBuilder + AddKafkaConsumer<T>. Supports envelope or raw-DTO handler signatures, optional CancellationToken, startup validation, optional IProcessedEventStore for idempotency, and configurable commit mode (at-least-once or auto-periodic). |
|
|
Tributary.Kafka.Producer
Kafka producer runtime for .NET, built on Akka.NET Streams. One DI line (AddSharedKafkaProducer) and one call (IEventProducer.PublishAsync) to publish events to Kafka. Every message is wrapped in an EventEnvelope with auto-generated event-id, event-type, occurred-at, and optional tenant-id headers. Idempotent producer is enabled by default. Config-driven SSL/SASL — works against Aiven, AWS MSK, Confluent Cloud, or self-hosted Kafka with no code changes. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated | |
|---|---|---|---|
| 1.5.67 | 3,954 | 4/28/2026 | |
| 1.5.59 | 5,402 | 1/27/2026 | |
| 1.5.55 | 9,307 | 10/27/2025 | |
| 1.5.46 | 7,113 | 8/12/2025 | |
| 1.5.40.1 | 93,470 | 3/25/2025 | |
| 1.5.40 | 3,970 | 3/24/2025 | |
| 1.5.39 | 4,064 | 3/19/2025 | |
| 1.5.39-beta2 | 202 | 3/14/2025 | |
| 1.5.39-beta1 | 233 | 3/13/2025 | |
| 1.5.38 | 7,440 | 3/5/2025 | |
| 1.5.37 | 8,183 | 2/6/2025 | |
| 1.5.35 | 22,203 | 1/20/2025 | |
| 1.5.33 | 4,835 | 12/26/2024 | |
| 1.5.30 | 20,045 | 10/3/2024 | |
| 1.5.29 | 3,947 | 10/1/2024 | |
| 1.5.15 | 18,835 | 1/11/2024 | |
| 1.5.13.1 | 5,205 | 10/4/2023 | |
| 1.5.13 | 3,557 | 10/4/2023 | |
| 1.5.8 | 8,416 | 6/16/2023 | |
| 1.2.2 | 20,391 | 10/21/2022 |
[Upgraded to Akka.NET v1.4.45](https://github.com/akkadotnet/akka.net/releases/tag/1.4.45)