Akka.Streams.Kafka
1.1.4
Prefix Reserved
See the version list below for details.
dotnet add package Akka.Streams.Kafka --version 1.1.4
NuGet\Install-Package Akka.Streams.Kafka -Version 1.1.4
<PackageReference Include="Akka.Streams.Kafka" Version="1.1.4" />
paket add Akka.Streams.Kafka --version 1.1.4
#r "nuget: Akka.Streams.Kafka, 1.1.4"
// Install Akka.Streams.Kafka as a Cake Addin #addin nuget:?package=Akka.Streams.Kafka&version=1.1.4 // Install Akka.Streams.Kafka as a Cake Tool #tool nuget:?package=Akka.Streams.Kafka&version=1.1.4
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. |
.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.25)
- Confluent.Kafka (>= 1.7.0)
NuGet packages (1)
Showing the top 1 NuGet packages that depend on Akka.Streams.Kafka:
Package | Downloads |
---|---|
AkkaDotModule.Webnori
Package Description |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.5.30 | 1,541 | 10/3/2024 |
1.5.29 | 152 | 10/1/2024 |
1.5.15 | 8,080 | 1/11/2024 |
1.5.13.1 | 1,568 | 10/4/2023 |
1.5.13 | 151 | 10/4/2023 |
1.5.8 | 4,761 | 6/16/2023 |
1.5.0 | 116,814 | 3/4/2023 |
1.4.49 | 2,945 | 1/27/2023 |
1.2.2 | 13,251 | 10/21/2022 |
1.2.1 | 76,881 | 1/26/2022 |
1.2.0 | 1,248 | 11/17/2021 |
1.1.4 | 4,264 | 9/8/2021 |
1.1.3 | 2,499 | 5/24/2021 |
1.1.2 | 34,478 | 3/9/2021 |
1.1.1 | 3,363 | 12/16/2020 |
1.1.0 | 4,888 | 11/6/2020 |
1.0.1 | 2,539 | 5/27/2020 |
1.0.0 | 3,417 | 3/11/2020 |
1.0.0-rc2 | 403 | 3/10/2020 |
1.0.0-rc1 | 396 | 3/2/2020 |
1.0.0-beta2 | 626 | 2/18/2020 |
1.0.0-beta1 | 2,130 | 11/28/2019 |
0.5.0-beta | 463 | 8/7/2019 |
[Upgrade to Akka.NET 1.4.25](https://github.com/akkadotnet/akka.net/releases/tag/1.4.25)
[Optimize Consumer polling](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/217)
[Fix topic partition assignment and revocation bug](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/221)
[Fix failing Kafka seek causing plain partitioned source to fail](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/225)
__Kafka consumer client polling optimization__
These are the before and after benchmark comparison of the consumer stream throughput.
`KafkaClientThroughput` uses the native client as the baseline number for comparison.
__Before:__
``` ini
BenchmarkDotNet=v0.13.1, OS=Windows 10.0.19041.1165 (2004/May2020Update/20H1)
AMD Ryzen 9 3900X, 1 CPU, 24 logical and 12 physical cores
.NET SDK=5.0.201
[Host] : .NET Core 3.1.13 (CoreCLR 4.700.21.11102, CoreFX 4.700.21.11602), X64 RyuJIT
Job-WTNALI : .NET Core 3.1.13 (CoreCLR 4.700.21.11102, CoreFX 4.700.21.11602), X64 RyuJIT
InvocationCount=2000 IterationCount=100 MinWarmupIterationCount=10
UnrollFactor=1
```
| Method | Mean | Error | StdDev |
|---------------------- |---------:|----------:|----------:|
| PlainSinkThroughput | 892.8 μs | 225.73 μs | 590.69 μs |
| KafkaClientThroughput | 120.4 μs | 17.29 μs | 45.24 μs |
__After:__
``` ini
BenchmarkDotNet=v0.13.1, OS=Windows 10.0.19041.1165 (2004/May2020Update/20H1)
AMD Ryzen 9 3900X, 1 CPU, 24 logical and 12 physical cores
.NET SDK=5.0.201
[Host] : .NET Core 3.1.13 (CoreCLR 4.700.21.11102, CoreFX 4.700.21.11602), X64 RyuJIT
Job-WTNALI : .NET Core 3.1.13 (CoreCLR 4.700.21.11102, CoreFX 4.700.21.11602), X64 RyuJIT
InvocationCount=20000 IterationCount=20 MinWarmupIterationCount=5
UnrollFactor=1
```
| Method | Mean | Error | StdDev |
|---------------------- |---------:|--------:|--------:|
| PlainSinkThroughput | 134.0 μs | 0.97 μs | 1.12 μs |
| KafkaClientThroughput | 135.2 μs | 0.21 μs | 0.24 μs |