Akka.Streams.Kafka v1.5.30

1.5.30 October 3rd 2024

• Upgraded to Akka.NET v1.5.30
• Bump Confluent.Kafka to 2.4.0

1.5.29 October 1st 2024

Note

Deprecated

Deprecated due to Akka.NET 1.5.29 deprecation. Please use 1.5.30 instead.

• Upgraded to Akka.NET v1.5.29
• Bump Confluent.Kafka to 2.4.0

1.5.15 January 11 2024

• Upgraded to Akka.NET v1.5.15

1.5.13.1 October 4 2023

• Publish NuGet package symbol file

1.5.13 October 4 2023

• Upgraded to Akka.NET v1.5.13
• Bump Confluent.Kafka to 2.2.0

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• cf4b09c Update RELEASE_NOTES.md for 1.5.30 release (#409)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.29

1.5.29 October 1st 2024

• Upgraded to Akka.NET v1.5.29
• Bump Confluent.Kafka to 2.4.0

1.5.15 January 11 2024

• Upgraded to Akka.NET v1.5.15

1.5.13.1 October 4 2023

• Publish NuGet package symbol file

1.5.13 October 4 2023

• Upgraded to Akka.NET v1.5.13
• Bump Confluent.Kafka to 2.2.0

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• 1f564cf Update RELEASE_NOTES.md for 1.5.29 release (#408)
• cd5ae1f fix partition sample (#406)
• 7ffeb3c Bump AkkaVersion from 1.5.15 to 1.5.29 (#407)
• 776d1b1 Bump xunit from 2.5.3 to 2.8.1 (#401)
• 96ae6e3 Bump Microsoft.NET.Test.Sdk from 17.7.2 to 17.10.0 (#404)
• 822055a Bump BenchmarkDotNet from 0.13.8 to 0.13.12 (#400)
• 51bce53 Bump xunit.runner.visualstudio from 2.5.6 to 2.8.1 (#403)
• 1999a02 Bump Confluent.Kafka from 2.2.0 to 2.4.0 (#402)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.15

1.5.15 January 11 2024

• Upgraded to Akka.NET v1.5.15

1.5.13.1 October 4 2023

• Publish NuGet package symbol file

1.5.13 October 4 2023

• Upgraded to Akka.NET v1.5.13
• Bump Confluent.Kafka to 2.2.0

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• cf03697 Update RELEASE_NOTES.md for 1.5.15 release (#398)
• 9552b02 Bump AkkaVersion from 1.5.13 to 1.5.15 (#397)
• 5e2a051 Bump Microsoft.SourceLink.GitHub from 1.1.1 to 8.0.0 (#393)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.13.1

1.5.13.1 October 4 2023

• Publish NuGet package symbol file

1.5.13 October 4 2023

• Upgraded to Akka.NET v1.5.13
• Bump Confluent.Kafka to 2.2.0

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• a7df8ac Update nuget push url in release script (#382)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.13

1.5.13 October 4 2023

• Upgraded to Akka.NET v1.5.13
• Bump Confluent.Kafka to 2.2.0

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• 3fa9352 Update RELEASE_NOTES.md for 1.5.13 release (#381)
• 1446886 Bump FakeItEasy from 7.3.1 to 7.4.0 (#378)
• 3bfeeb8 Bump Docker.DotNet from 3.125.13 to 3.125.15 (#380)
• 7a326ee Bump FluentAssertions from 6.10.0 to 6.12.0 (#379)
• e68bf32 Bump Confluent.Kafka from 2.1.1 to 2.2.0 (#360)
• aafd57a Bump AkkaVersion from 1.5.0 to 1.5.13 (#376)
• f4c43db Bump xunit.runner.visualstudio from 2.4.5 to 2.5.1 (#377)
• c658c91 Bump xunit from 2.4.2 to 2.5.1 (#375)
• b3587a0 Bump BenchmarkDotNet from 0.13.7 to 0.13.8 (#371)
• f1e6b62 Modernize solution (#374)

See More

• ccd20bb Bump Docker.DotNet from 3.125.14 to 3.125.15 (#352)
• 4056146 Bump Microsoft.NET.Test.Sdk from 17.6.3 to 17.7.2 (#370)
• 985fbfa Bump FluentAssertions from 6.11.0 to 6.12.0 (#369)
• fc7b721 Bump BenchmarkDotNet from 0.13.6 to 0.13.7 (#366)
• 1112963 Bump AkkaVersion from 1.5.9 to 1.5.12 (#365)
• 94a9cff Bump BenchmarkDotNet from 0.13.5 to 0.13.6 (#359)
• aa439c1 Bump AkkaVersion from 1.5.8 to 1.5.9 (#361)
• dc56a01 Bump XunitVersion from 2.4.2 to 2.5.0 (#358)
• fa492b5 Bump Microsoft.NET.Test.Sdk from 17.6.2 to 17.6.3 (#357)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.8

1.5.8 June 16 2023

• Upgraded to Akka.NET v1.5.8

Changes:

• 569eb6f Added v1.5.8 release notes (#356)
• 780531a Upgrade to Akka.NET v1.5.8 (#355)
• f339a55 Bump AkkaVersion from 1.5.6 to 1.5.7 (#351)
• 0ee6526 Bump Microsoft.NET.Test.Sdk from 17.5.0 to 17.6.2 (#354)
• 0cca39c Bump FakeItEasy from 7.3.1 to 7.4.0 (#345)
• 34bc548 Bump Confluent.Kafka from 2.0.2 to 2.1.1 (#348)
• aaeae27 Bump AkkaVersion from 1.5.4 to 1.5.6 (#349)
• 8ac3671 Bump AkkaVersion from 1.5.3 to 1.5.4 (#346)
• aa842b1 Bump Docker.DotNet from 3.125.13 to 3.125.14 (#342)
• 09b5303 Bump FluentAssertions from 6.10.0 to 6.11.0 (#344)

See More

• b03d001 Bump AkkaVersion from 1.5.1 to 1.5.3 (#343)
• b295171 Bump AkkaVersion from 1.5.0 to 1.5.1 (#339)
• b5d26cd Bump Microsoft.NET.Test.Sdk from 17.4.1 to 17.5.0 (#333)

This list of changes was auto generated.

Akka.Streams.Kafka v1.5.0

1.5.0 March 02 2023

• Upgraded to Akka.NET v1.5.0

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• 4f7131c Add akka.net 1.5.0 support (#337)
• 260d513 Bump Docker.DotNet from 3.125.12 to 3.125.13 (#334)
• e12f2e3 Bump BenchmarkDotNet from 0.13.4 to 0.13.5 (#332)
• 9570119 fixed various build warnings (#331)
• debf471 Bump FluentAssertions from 6.9.0 to 6.10.0 (#330)

This list of changes was auto generated.

Akka.Streams.Kafka v1.4.49

1.4.49 January 27 2023

Akka.Streams.Kafka version will now be in lock-step with its Akka.NET package version.

• Upgraded to Akka.NET v1.4.49
• Handle exceptions thrown from kafka message processing
• Bump Confluent.Kafka from 1.9.3 to 2.0.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• af113b7 Downgrade sample project target framework to netcoreapp3.1 (#329)
• cb9a813 Update release script with .NET SDK 7.0 (#328)
• 5433e17 Update RELEASE_NOTES.md for v1.4.49 release (#326)
• 95a6ce2 Bump Confluent.Kafka from 1.9.3 to 2.0.2 (#325)
• 9c74de7 Bump AkkaVersion from 1.4.45 to 1.4.48 (#320)
• c95ea39 Handle any exceptions returned from ProcessResult (#324)
• a85d332 Bump BenchmarkDotNet from 0.13.3 to 0.13.4 (#322)
• e27cb2a Bump FluentAssertions from 6.8.0 to 6.9.0 (#321)
• 2759b65 Bump XunitVersion from 2.4.1 to 2.4.2 (#299)
• 4177c3c Bump FluentAssertions from 6.4.0 to 6.8.0 (#314)

See More

• 3540b3e Bump Microsoft.NET.Test.Sdk from 17.4.0 to 17.4.1 (#318)
• 0b7a8ec Bump BenchmarkDotNet from 0.13.2 to 0.13.3 (#319)
• 2f49854 Bump Microsoft.NET.Test.Sdk from 17.3.2 to 17.4.0 (#315)
• 390c93a Bump Microsoft.NET.Test.Sdk from 17.3.1 to 17.3.2 (#309)

This list of changes was auto generated.

Akka.Streams.Kafka v1.2.2

1.2.2 October 21 2022

• Upgraded to Akka.NET v1.4.45

Changes:

• 12de7d1 Update windows-release.yaml
• 63dc40f Update nightly-builds.yaml
• bdd18de Update RELEASE_NOTES.md
• 10b0b20 Bump AkkaVersion from 1.4.43 to 1.4.45 (#313)
• 67409ab Update vmImage from `vs2017-win2016' to 'windows-2019' (#311)
• 9a83500 Bump AkkaVersion from 1.4.41 to 1.4.43 (#310)
• 27a7553 Bump Microsoft.NET.Test.Sdk from 17.3.0 to 17.3.1 (#303)
• 258c166 Bump Docker.DotNet from 3.125.10 to 3.125.12 (#307)
• dca577e Bump Confluent.Kafka from 1.9.2 to 1.9.3 (#306)
• 0c6c262 Bump AkkaVersion from 1.4.39 to 1.4.41 (#304)

See More

• 83990fc Bump Confluent.Kafka from 1.9.0 to 1.9.2 (#300)
• 70fd8ef Bump BenchmarkDotNet from 0.13.1 to 0.13.2 (#302)
• 58be765 Bump Microsoft.NET.Test.Sdk from 17.2.0 to 17.3.0 (#301)
• 5bc3e2c Bump FakeItEasy from 7.3.0 to 7.3.1 (#283)
• 7f9bdba Bump Tmds.ExecFunction from 0.5.0 to 0.6.0 (#296)
• 27a522a Bump Docker.DotNet from 3.125.5 to 3.125.10 (#297)
• 9ae966b Bump Microsoft.NET.Test.Sdk from 17.1.0 to 17.2.0 (#291)
• 010612a Bump Confluent.Kafka from 1.8.2 to 1.9.0 (#295)
• ef9155a Bump AkkaVersion from 1.4.33 to 1.4.39 (#294)
• 60cd56d Add manual partition sample (#286)
• 7625ecf Bump Microsoft.NET.Test.Sdk from 17.0.0 to 17.1.0 (#281)
• 53ad846 Bump AkkaVersion from 1.4.32 to 1.4.33 (#280)
• 2b788fe Add spec for #276 (#277)
• 52210ba bugfix: NullReferenceException on absent connection-checker in config (#276)

This list of changes was auto generated.

Akka.Streams.Kafka v1.2.1

1.2.1 January 25 2022

• Bump Akka.NET to 1.4.32
• Fix Kafka polling method
• Fix excessively high CPU consumption

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:

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:

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

Changes:

• 739a765 Version 1.2.1 Release
• 7d06068 Merge branch 'master' into master
• 828fd0e Merge branch 'dev'
• 8b5aed3 Update RELEASE_NOTES.md for 1.2.1 release (#273)
• b9852f5 Bump FakeItEasy from 7.2.0 to 7.3.0 (#267)
• 5e6ebc0 Fix KafkaConsumerActor excessive CPU consumption (#272)
• 25c544e Bump FluentAssertions from 6.2.0 to 6.4.0 (#269)
• 4bc0581 Bump AkkaVersion from 1.4.31 to 1.4.32 (#268)
• ce57b10 Add CPU profiling benchmark project (#271)
• 4e626c0 Bump AkkaVersion from 1.4.28 to 1.4.31 (#265)

See More

• 52b6c51 Fix Kafka polling method (#262)
• 9ed12c9 Add convenience method documentation (#261)
• 4931485 Add convenience methods and code cleanup (#260)

This list of changes was auto generated.