Akka.Streams.Kafka
1.2.1
Prefix Reserved
See the version list below for details.
dotnet add package Akka.Streams.Kafka --version 1.2.1
NuGet\Install-Package Akka.Streams.Kafka -Version 1.2.1
<PackageReference Include="Akka.Streams.Kafka" Version="1.2.1" />
paket add Akka.Streams.Kafka --version 1.2.1
#r "nuget: Akka.Streams.Kafka, 1.2.1"
// Install Akka.Streams.Kafka as a Cake Addin #addin nuget:?package=Akka.Streams.Kafka&version=1.2.1 // Install Akka.Streams.Kafka as a Cake Tool #tool nuget:?package=Akka.Streams.Kafka&version=1.2.1
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.32)
- Confluent.Kafka (>= 1.8.2)
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,604 | 10/3/2024 |
| 1.5.29 | 156 | 10/1/2024 |
| 1.5.15 | 8,145 | 1/11/2024 |
| 1.5.13.1 | 1,581 | 10/4/2023 |
| 1.5.13 | 151 | 10/4/2023 |
| 1.5.8 | 4,768 | 6/16/2023 |
| 1.5.0 | 117,794 | 3/4/2023 |
| 1.4.49 | 2,957 | 1/27/2023 |
| 1.2.2 | 13,293 | 10/21/2022 |
| 1.2.1 | 77,282 | 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 | 35,178 | 3/9/2021 |
| 1.1.1 | 3,364 | 12/16/2020 |
| 1.1.0 | 4,901 | 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 |
[Bump Akka.NET to 1.4.32](https://github.com/akkadotnet/akka.net/releases/tag/1.4.32)
[Fix Kafka polling method](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/262)
[Fix excessively high CPU consumption](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/234)
This is a minor version release that addresses a bug in the underlying `Confluent.Kafka` library. The `Confluent.Kafka.AdminClient` class have a very tight internal update loop that will consume a lot of CPU resource while it is instantiated.
The update fixed the high idle CPU consumption as shown in these CPU usage benchmark numbers:
``` ini
BenchmarkDotNet=v0.13.1, OS=Windows 10.0.19041.1415 (2004/May2020Update/20H1)
AMD Ryzen 9 3900X, 1 CPU, 24 logical and 12 physical cores
.NET SDK=6.0.100
[Host] : .NET Core 3.1.20 (CoreCLR 4.700.21.47003, CoreFX 4.700.21.47101), X64 RyuJIT
Sample duration: 5000 ms
```
__Before:__
| CPU Usage Mode | Mean | StdErr | StdDev | Median | Maximum |
|----------------|-------------:|----------:|----------:|-------------:|-------------:|
| User | 4,954.688 ms | 12.780 ms | 40.414 ms | 4,968.750 ms | 5,000.000 ms |
| Kernel | 9.375 ms | 2.421 ms | 7.655 ms | 15.625 ms | 15.625 ms |
| Total | 4,964.062 ms | 13.082 ms | 41.369 ms | 4,984.375 ms | 5,015.625 ms |
__After:__
| CPU Usage Mode | Mean | StdErr | StdDev | Median | Maximum |
|----------------|---------:|---------:|---------:|---------:|---------:|
| User | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms |
| Kernel | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms |
| Total | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms | 0.000 ms |
These changes have no impact on throughput performance of the plugin as seen in these benchmark numbers:
``` ini
BenchmarkDotNet=v0.13.1, OS=Windows 10.0.19041.1415 (2004/May2020Update/20H1)
AMD Ryzen 9 3900X, 1 CPU, 24 logical and 12 physical cores
.NET SDK=6.0.100
[Host] : .NET Core 3.1.20 (CoreCLR 4.700.21.47003, CoreFX 4.700.21.47101), X64 RyuJIT
InvocationCount=2000 IterationCount=80 MinWarmupIterationCount=5
UnrollFactor=1
```
__Before:__
| Method | Mean | Error | StdDev | Median |
|---------------------- |---------:|---------:|---------:|---------:|
| PlainSinkThroughput | 128.9 μs | 12.04 μs | 31.30 μs | 112.5 μs |
| KafkaClientThroughput | 120.7 μs | 17.21 μs | 45.03 μs | 111.0 μs |
__After:__
| Method | Mean | Error | StdDev | Median |
|---------------------- |---------:|---------:|---------:|---------:|
| PlainSinkThroughput | 123.3 μs | 6.30 μs | 14.36 μs | 129.4 μs |
| KafkaClientThroughput | 117.5 μs | 18.61 μs | 48.70 μs | 110.0 μs |