Akka.Streams.Kafka v1.1.4

1.1.4 September 08 2021

• Upgrade to Akka.NET 1.4.25
• Optimize Consumer polling
• Fix topic partition assignment and revocation bug
• Fix failing Kafka seek causing plain partitioned source to fail

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:

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:

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

1.1.3 May 24 2021

• Add ConnectionChecker feature
• Upgrade to Confluent.Kafka 1.7.0
• Upgrade to Akka.NET 1.4.20
• Added support for custom statistics handler

1.1.2 March 09 2021

• Upgraded to Akka.NET v1.4.16
• Upgrade to Confluent.Kafka 1.6.2
• Use Decider for choosing producer background error handling

1.1.1 December 16 2020

• Upgraded to Akka.NET v1.4.13
• Upgrade to Confluent.Kafka 1.5.3
• Make Akka.Streams.Kafka client compatible with Azure Event Hub Kafka API

Changes:

• 9283389 Merge pull request #227 from akkadotnet/dev
• c8fd61a Update RELEASE_NOTES.md for 1.1.4 release (#222)
• 1f9d39b Upgrade to Akka.NET v1.4.25 (#226)
• 684f6f7 Fix failing Kafka seek causing plain partitioned source to fail (#225)
• d58ba71 Merge pull request #224 from Arkatufus/Fix_consumer_actor_request_bug
• 2965066 Merge branch 'dev' into Fix_consumer_actor_request_bug
• 61d863c Fix consumer actor, requests removed erroneously
• 9964610 Bump Docker.DotNet from 3.125.4 to 3.125.5 (#223)
• 36ca073 Fix bug in topic partition assignment and revocation code (#221)
• e7bae2b Bump Microsoft.NET.Test.Sdk from 16.10.0 to 16.11.0 (#215)

See More

• c688a8f Fix performance problems with the Kafka consumer (#217)
• 3cd825b Bump AkkaVersion from 1.4.23 to 1.4.24 (#216)
• 8bbad30 Bump FluentAssertions from 5.10.3 to 6.1.0 (#218)
• 9b1c873 Bump AkkaVersion from 1.4.21 to 1.4.23 (#213)
• 64e1435 Bump AkkaVersion from 1.4.20 to 1.4.21 (#211)
• 37888b9 Bump Microsoft.NET.Test.Sdk from 16.9.4 to 16.10.0 (#210)

This list of changes was auto generated.

Akka.Streams.Kafka v1.1.3

1.1.3 May 24 2021

• Add ConnectionChecker feature
• Upgrade to Confluent.Kafka 1.7.0
• Upgrade to Akka.NET 1.4.20
• Added support for custom statistics handler

Changes:

• 625007d Merge pull request #208 from IgorFedchenko/release-1.1.3
• 252ba73 Merge branch 'dev' into release-1.1.3
• b8a20f6 Merge pull request #207 from IgorFedchenko/update-to-1.1.3
• 64f29bc Updated RELEASE_NOTES for 1.1.3
• 1f9d0d8 Merge pull request #205 from IgorFedchenko/reverr-204 [ #204 ]
• fabfe71 Merge pull request #206 from IgorFedchenko/backport-204 [ #204 ]
• b44bca8 Revert #204 master branch PR (backported to dev branch)
• fa916be Merge pull request #204 from jsb81/statisticshandler
• e652ba5 Merge pull request #204 from jsb81/statisticshandler
• 9e83c13 statisticsHandler HasValue checking simplified

See More

• 03f92bf StatisticsHandler and WithStatisticsHandler methods moved into ISubscription interface
• 9840a6b autoformatting removed
• aff5cc8 autoformatting removed
• 04d81e5 autoformatting removed
• 032b206 Add support for custom statistics handler
• 8d37c9d Add support for custom statistics handler
• 76789a6 Bump Confluent.Kafka from 1.6.3 to 1.7.0 (#202)
• 38945f6 Bump AkkaVersion from 1.4.19 to 1.4.20 (#200)
• 3cb447b Upgrade to GitHub-native Dependabot (#199)
• 412208c Merge pull request #198 from akkadotnet/dependabot/nuget/AkkaVersion-1.4.19
• 067d405 Bump AkkaVersion from 1.4.18 to 1.4.19
• 090d791 Use Consumer.Close in code defensively (#193)
• 7757479 Bump Microsoft.NET.Test.Sdk from 16.9.1 to 16.9.4 (#197)
• cc7d080 Bump Confluent.Kafka from 1.6.2 to 1.6.3 (#192)
• 766bd6b Bump AkkaVersion from 1.4.17 to 1.4.18 (#194)
• 82b7f90 Merge pull request #190 from Arkatufus/Add_ConnectionChecker
• f341521 Fix typo
• b621d9a Merge branch 'dev' into Add_ConnectionChecker
• 630e587 Add ConnectionChecker
• f8a39af Bump AkkaVersion from 1.4.16 to 1.4.17 (#189)

This list of changes was auto generated.

Akka.Streams.Kafka v1.1.2

1.1.2 March 09 2021

• Upgraded to Akka.NET v1.4.16
• Upgrade to Confluent.Kafka 1.6.2
• Use Decider for choosing producer background error handling

1.1.1 December 16 2020

• Upgraded to Akka.NET v1.4.13
• Upgrade to Confluent.Kafka 1.5.3
• Make Akka.Streams.Kafka client compatible with Azure Event Hub Kafka API

Changes:

• 6a658f0 Merge pull request #188 from akkadotnet/dev
• 7aececd Updated RELEASE_NOTES to 1.1.2 (#186)
• f3dab29 Use Decider for choosing producer background error handling (#185)
• 2420dc7 Bump Confluent.Kafka from 1.5.3 to 1.6.2 (#183)
• 7027f23 Merge pull request #181 from akkadotnet/dependabot/nuget/Microsoft.NET.Test.Sdk-16.9.1
• ce38f12 Merge branch 'dev' into dependabot/nuget/Microsoft.NET.Test.Sdk-16.9.1
• af9ec15 Merge pull request #182 from IgorFedchenko/fix-racy-spec
• ed1bd28 Updated racy spec
• 727c6d7 Merge branch 'dev' into fix-racy-spec
• 7832f8d Fix racy spec

See More

• 16cd590 Bump Microsoft.NET.Test.Sdk from 16.8.3 to 16.9.1
• 4b36f98 Bump AkkaVersion from 1.4.15 to 1.4.16 (#178)
• 68f49fe Merge pull request #180 from Arkatufus/Fix_DockerClient.Images.ListImagesAsync
• fca2b04 Force KafkaClient to connect to 127.0.0.1, localhost is buggy (selects between IPV4 and IPV6 randomly)
• 3c121d1 Force connection to 127.0.0.1 instead of localhost
• 908605d Force Kafka client to choose IPV4 instead of IPV6
• 867c7d7 Merge branch 'dev' into Fix_DockerClient.Images.ListImagesAsync
• 3a9a347 Fix DockerClient.Images.ListImagesAsync(MatchName) doesn't work anymore
• 03d1bcd Bump AkkaVersion from 1.4.13 to 1.4.15 (#177)
• 56bbd0b Bump Microsoft.NET.Test.Sdk from 16.7.1 to 16.8.3 (#166)
• bd7b7f5 Merge pull request #174 from IgorFedchenko/minor-test-refactoring
• 63d288d Refactored one of the tests to not use obsolete properties

This list of changes was auto generated.

Akka.Streams.Kafka v1.1.1

1.1.1 December 16 2020

• Upgraded to Akka.NET v1.4.13
• Upgrade to Confluent.Kafka 1.5.3
• Make Akka.Streams.Kafka client compatible with Azure Event Hub Kafka API

Changes:

• e68fb30 Merge pull request #173 from akkadotnet/dev
• c1113bc added v1.1.1 release notes (#172)
• 68b7a0f upgrade to Akka.NET v1.4.13 (#171)
• cc02ca2 Make kafka work with event hub (#167)
• 1d97f1d Merge pull request #170 from IgorFedchenko/bump-kafka
• 41beeac Logging total consumed messages
• 6e6c9e8 Bump Confluent.Kafka from 1.5.2 to 1.5.3
• e40cbef Merge pull request #168 from IgorFedchenko/update-akka
• 3b8f499 Using async API in failed test
• 493c3d7 Updated Akka.NET version

This list of changes was auto generated.

Akka.Streams.Kafka v1.1.0

1.1.0 November 6 2020

• Upgraded to Akka.NET v1.4.11
• Upgrade to Confluent.Kafka 1.5.2 and AutoCreateTopicsEnabled setting
• Resolved: Broker: Unknown topic or partition after upgrading to kafka 1.5.0+
• Added support for custom IPartitionEventHandler instances in subscriptions

Changes:

• 27fb68a Merge pull request #162 from akkadotnet/dev
• 82adb99 Update RELEASE_NOTES.md
• b1a6e48 Merge pull request #161 from akkadotnet/update-common-props
• 6f59e1e Merge branch 'master' into update-common-props
• f2c23fd Added release notes for Akka.Streams.Kafka 1.1.1 (#160)
• e031490 Bump AkkaVersion from 1.4.10 to 1.4.11 (#159)
• 9c6d1b6 Bump Docker.DotNet from 3.125.2 to 3.125.4 (#145)
• c4ac26a Bump Microsoft.NET.Test.Sdk from 16.6.1 to 16.7.1 (#152)
• ada99f4 Upgrade to Akka.Streams.Kafka 1.5.2 and AutoCreateTopicsEnabled setting (#157)
• 3dd904e Added support for custom IPartitionEventHandler instances in subscriptions (#154)

See More

• 8c69d80 Nightly build support (#155)
• 4b38a64 Bump AkkaVersion from 1.4.9 to 1.4.10 (#151)
• 1b14ee2 Bump AkkaVersion from 1.4.7 to 1.4.9 (#143)
• 29dd9d2 fixed Akka.Streams.Kafka version suffix (#137)

This list of changes was auto generated.

Akka.Streams.Kafka v1.0.1

1.0.1 May 27 2020

Maintenance Release for Akka.Streams.Kafka 1.0

• Updated to use Akka.NET v1.4.7
• Upgraded Confluent driver to latest.

Changes:

• 60d937e fixed Akka.Streams.Kafka version suffix (#137) (#138)
• e251d25 Merge pull request #136 from akkadotnet/dev
• 8d42454 added v1.0.1 release notes
• 8d5970e Bump Microsoft.NET.Test.Sdk from 16.6.0 to 16.6.1 (#127)
• 74244c0 Bump Confluent.Kafka from 1.4.0 to 1.4.3 (#134)
• 0f59cea Bump AkkaVersion from 1.4.4 to 1.4.7 (#135)
• 1ccbddb Merge pull request #126 from IgorFedchenko/consumer-auto-commit-fix
• 64159f2 Disabled auto-commit feature for tests
• 31c1fd6 Bump AkkaVersion from 1.4.1 to 1.4.4
• 17b23c0 Bump Microsoft.NET.Test.Sdk from 16.5.0 to 16.6.0 (#125)

See More

• 4f58e3e Bump FluentAssertions from 5.10.2 to 5.10.3 (#121)
• 2a8107e Bump Confluent.Kafka from 1.3.0 to 1.4.0 (#124)
• 3f34862 Update readme (#118)

This list of changes was auto generated.

Akka.Streams.Kafka v1.0.0

1.0.0 March 10 2020

Stable release of Akka.Streams.Kafka

• Updated to use Akka.NET v1.4.1.

Changes:

• ffc4c2b Merge pull request #111 from akkadotnet/dev
• 83ba2e2 Update Akka to 1.4.1 (#117)
• 6237eb0 added 1.0.0-rc2 release notes (#115)
• 4a40c94 Bump AkkaVersion from 1.4.1-rc2 to 1.4.1-rc3 (#116)
• 3b00205 upgraded to AKka.NET v1.4.1-rc2 (#114)
• e3f6fa2 Fixes for batch committer flow and commit refreshing (#112)
• 9452af9 added v1.0.0-RC1 release notes (#110)
• 7433157 upgraded to Akka.NET v1.4.1-RC1 (#109)
• cf98b8f upgrade build system to .NET Core 3.1 (#108)
• 8cc1a19 updated build system to support betas (#106)

See More

• 300abde added v1.0.2-beta2 release notes (#105)
• b180171 Merge pull request #104 from IgorFedchenko/fix/immutable-array-init
• df75208 Fix immutable array initialization
• e3c69a2 Bump FluentAssertions from 5.10.0 to 5.10.2 (#102)
• 2c5546e Bump Microsoft.NET.Test.Sdk from 16.4.0 to 16.5.0 (#101)
• 1d437c1 PlainPartitionedSource_should_work racy test fix (#100)
• 0c1035e Bump FluentAssertions from 5.9.0 to 5.10.0 (#96)
• cf853af Bump AkkaVersion from 1.4.0-beta3 to 1.4.0-beta4 (#98)
• 875b806 cleaned up the .CSPROJ files for v1.0.0-beta1 (#93)
• 5cb78a2 support-custom-nuget-tags (#92)
• 4ca03a2 Updated README and ReleaseNotes (#91)
• 575d88a Bump Confluent.Kafka from 1.2.1 to 1.2.2 (#90)
• 89c05dc Implemented transactional source (#84)
• ce80944 TransactionalFlow and TransactionalSink support (#86)
• 21fd138 Bump Microsoft.NET.Test.Sdk from 16.3.0 to 16.4.0 (#89)
• ed5dab8 FlowWithContext (#83)
• f418e7d Bump AkkaVersion from 1.4.0-beta2 to 1.4.0-beta3 (#88)
• b5e5740 Added source creation method (#81)
• ab26dfc PlainPartitionedWithOffset source (#80)
• 3633d97 Committable partitioned source (#79)
• 8e2faf7 Removed nightly feed (#78)
• 8456c4a PlainPartitionedSource (#65)
• 1b3ddf8 Bump Confluent.Kafka from 1.2.0 to 1.2.1 (#77)
• 4ea68b4 IControl implementation (#71)
• 68a63eb Bump Confluent.Kafka from 1.1.0 to 1.2.0 (#68)
• 0fcdf56 Bump Microsoft.NET.Test.Sdk from 15.9.0 to 16.3.0 (#69)
• f7b179a Bump FluentAssertions from 5.2.0 to 5.9.0 (#70)
• 146138d CommitWithMetadataSource (#64) [ #66 ]
• 669d1a1 SourceWithOffsetContext (#62)
• 4f75ed8 Implemented CommittableExternalSource (#63)
• 5f5bd87 Kafka consumer AtMostOnceSource (#60)
• 7ca3d42 close #50 - upgraded to v1.4.0-beta2 (#61)
• 0f0f31b Fix requests management (#59)
• a98057d External plain source (#56)
• 7de4f82 Added option to customize partition events by stage logic subclasses (#52)
• f508461 Added option to reuse existing container (#53)
• 3979fe4 Pause/Resume partitions on demand (#54)
• f316118 Base stage with consuming actor (#48)
• 522c7bd Added resource cleanup on start/stop testing (#47)
• 45a95ed Refactor to make consumer stages to use base classes (#45)
• 274468a Fix hard-coded groupId value for CommittableConsumerSource (#44)
• 5aa6e67 Use fixed docker image tag instead of "latest" tag (#43)
• 032e9cd Removed useless docker hosts setup (#42)
• 0e83dab Make tests pass (#41)
• c609061 Update Confluence.Kafka to 1.1.0 (#30)
• 7f05b47 have build script fail if the tests don't pass (#32)
• 55dd954 Merge pull request #31 from Aaronontheweb/fix-build-script
• 6bfd957 added TRX logging to build system
• 38e4a66 Merge pull request #29 from akkadotnet/dev
• a22f9c1 added updated Windows Release pipeline (#28)
• 342e1e9 upgraded to Akka.NET v1.3.14 (#27)
• f7538b5 Added updated v0.5.0 release notes (#26)
• 9bb6c76 Disabled PR validation for Windows Release pipeline (#25)
• 659e33f upgrade to Akka.NET v1.3.13 (#24)
• 299338a removed duplicate solution, docker-compose (#23)
• 791c48a Attribute copyright to .NET Foundation
• 61b5cda Merge pull request #22 from akkadotnet/remove-duplicate-license
• b7e266c Replacing with the Alpakka markdown license
• e562590 Merge pull request #21 from Aaronontheweb/azure-pipelines
• 90ba02d added Azure pipelines files and build scripts
• eb40b60 Merge pull request #20 from Aaronontheweb/borrow-alpakka-implementation
• 8735cb7 upgraded to .NET Core 2.0
• 45c1c77 replaced existing library wholesale with Alpakka solution
• aa26d15 Merge pull request #17 from trimsane/dev
• c69d9d4 Moving to Akka.Streams 1.3.5
• a26665a fix naming
• f51fb94 Committable Source (#12)
• 17874df Added Pause/Resume (#15)
• 032726a Use deciders for exception handling (#14)
• 86df3c6 Better logging (#13)
• c46902a Added PartitionId to ProduceRecord
• 78dfced fix consumer settings
• 464ffb1 Improved error handling (#8)
• 53a6b3c fix nuget
• 3e5e910 small tests refactoring
• b0ff8e6 Merge pull request #7 from Silv3rcircl3/dev
• 7418c49 only schedule timer if downstream is fast enough
• 1fbc1e9 Increase test timeout
• 1aae531 Unsubscribe on PostStop
• 02934e4 Merge pull request #6 from alexvaluyskiy/errorhandling
• 052323a Consumer error handling
• 919f7ea Error handling in the producer
• d100174 Merge pull request #5 from alexvaluyskiy/betterreadme
• 53db403 better readme
• c5cfa03 Merge pull request #4 from alexvaluyskiy/newsimpleconsumer
• 55e4fd6 Added MsgPack serializer
• 181d25a Fix consumer
• 539cf93 Changed Producer Flow
• c560f3a Flush messages in the producer
• 52c1568 Removed Result class
• b69ba56 Updated tests
• 9aa4e0b added tests
• c5e2023 update
• 4f0b075 fix build
• 67d2c7f initial
• 8dd8edf fix
• 7a4838a fix consumer
• 90abe9a KafkaConsumerActor
• e1d86a5 initial consumer
• f59936c fix async producer
• b1dc50b improved ProducerSettings
• 7580730 Create LICENSE
• c2addb1 fix nightly builds
• c5314ef fix publishing
• f1e3487 fix CI
• 9468ed4 added a badge
• a2a6206 appveyor
• 48449b4 added Readme

This list of changes was auto generated.

Akka.Streams.Kafka v1.0.0-rc2

1.0.0-rc2 March 10 2020

Stable release candidate of Akka.Streams.Kafka

• Updated to use Akka.NET v1.4.1-rc3 and offers stable API access to Akka.Streams.Kafka.
• Bugfix: Fixes for batch committer flow and commit refreshing

Changes:

• 6237eb0 added 1.0.0-rc2 release notes (#115)
• 4a40c94 Bump AkkaVersion from 1.4.1-rc2 to 1.4.1-rc3 (#116)
• 3b00205 upgraded to AKka.NET v1.4.1-rc2 (#114)
• e3f6fa2 Fixes for batch committer flow and commit refreshing (#112)
• 9452af9 added v1.0.0-RC1 release notes (#110)
• 7433157 upgraded to Akka.NET v1.4.1-RC1 (#109)
• cf98b8f upgrade build system to .NET Core 3.1 (#108)
• 8cc1a19 updated build system to support betas (#106)
• 300abde added v1.0.2-beta2 release notes (#105)
• b180171 Merge pull request #104 from IgorFedchenko/fix/immutable-array-init

See More

• df75208 Fix immutable array initialization
• e3c69a2 Bump FluentAssertions from 5.10.0 to 5.10.2 (#102)
• 2c5546e Bump Microsoft.NET.Test.Sdk from 16.4.0 to 16.5.0 (#101)
• 1d437c1 PlainPartitionedSource_should_work racy test fix (#100)
• 0c1035e Bump FluentAssertions from 5.9.0 to 5.10.0 (#96)
• cf853af Bump AkkaVersion from 1.4.0-beta3 to 1.4.0-beta4 (#98)
• 875b806 cleaned up the .CSPROJ files for v1.0.0-beta1 (#93)
• 5cb78a2 support-custom-nuget-tags (#92)
• 4ca03a2 Updated README and ReleaseNotes (#91)
• 575d88a Bump Confluent.Kafka from 1.2.1 to 1.2.2 (#90)
• 89c05dc Implemented transactional source (#84)
• ce80944 TransactionalFlow and TransactionalSink support (#86)
• 21fd138 Bump Microsoft.NET.Test.Sdk from 16.3.0 to 16.4.0 (#89)
• ed5dab8 FlowWithContext (#83)
• f418e7d Bump AkkaVersion from 1.4.0-beta2 to 1.4.0-beta3 (#88)
• b5e5740 Added source creation method (#81)
• ab26dfc PlainPartitionedWithOffset source (#80)
• 3633d97 Committable partitioned source (#79)
• 8e2faf7 Removed nightly feed (#78)
• 8456c4a PlainPartitionedSource (#65)
• 1b3ddf8 Bump Confluent.Kafka from 1.2.0 to 1.2.1 (#77)
• 4ea68b4 IControl implementation (#71)
• 68a63eb Bump Confluent.Kafka from 1.1.0 to 1.2.0 (#68)
• 0fcdf56 Bump Microsoft.NET.Test.Sdk from 15.9.0 to 16.3.0 (#69)
• f7b179a Bump FluentAssertions from 5.2.0 to 5.9.0 (#70)
• 146138d CommitWithMetadataSource (#64) [ #66 ]
• 669d1a1 SourceWithOffsetContext (#62)
• 4f75ed8 Implemented CommittableExternalSource (#63)
• 5f5bd87 Kafka consumer AtMostOnceSource (#60)
• 7ca3d42 close #50 - upgraded to v1.4.0-beta2 (#61)
• 0f0f31b Fix requests management (#59)
• a98057d External plain source (#56)
• 7de4f82 Added option to customize partition events by stage logic subclasses (#52)
• f508461 Added option to reuse existing container (#53)
• 3979fe4 Pause/Resume partitions on demand (#54)
• f316118 Base stage with consuming actor (#48)
• 522c7bd Added resource cleanup on start/stop testing (#47)
• 45a95ed Refactor to make consumer stages to use base classes (#45)
• 274468a Fix hard-coded groupId value for CommittableConsumerSource (#44)
• 5aa6e67 Use fixed docker image tag instead of "latest" tag (#43)
• 032e9cd Removed useless docker hosts setup (#42)
• 0e83dab Make tests pass (#41)
• c609061 Update Confluence.Kafka to 1.1.0 (#30)
• 7f05b47 have build script fail if the tests don't pass (#32)
• 55dd954 Merge pull request #31 from Aaronontheweb/fix-build-script
• 6bfd957 added TRX logging to build system
• a22f9c1 added updated Windows Release pipeline (#28)
• 342e1e9 upgraded to Akka.NET v1.3.14 (#27)
• f7538b5 Added updated v0.5.0 release notes (#26)
• 9bb6c76 Disabled PR validation for Windows Release pipeline (#25)
• 659e33f upgrade to Akka.NET v1.3.13 (#24)
• 299338a removed duplicate solution, docker-compose (#23)
• 791c48a Attribute copyright to .NET Foundation
• 61b5cda Merge pull request #22 from akkadotnet/remove-duplicate-license
• b7e266c Replacing with the Alpakka markdown license
• e562590 Merge pull request #21 from Aaronontheweb/azure-pipelines
• 90ba02d added Azure pipelines files and build scripts
• eb40b60 Merge pull request #20 from Aaronontheweb/borrow-alpakka-implementation
• 8735cb7 upgraded to .NET Core 2.0
• 45c1c77 replaced existing library wholesale with Alpakka solution
• aa26d15 Merge pull request #17 from trimsane/dev
• c69d9d4 Moving to Akka.Streams 1.3.5
• a26665a fix naming
• f51fb94 Committable Source (#12)
• 17874df Added Pause/Resume (#15)
• 032726a Use deciders for exception handling (#14)
• 86df3c6 Better logging (#13)
• c46902a Added PartitionId to ProduceRecord
• 78dfced fix consumer settings
• 464ffb1 Improved error handling (#8)
• 53a6b3c fix nuget
• 3e5e910 small tests refactoring
• b0ff8e6 Merge pull request #7 from Silv3rcircl3/dev
• 7418c49 only schedule timer if downstream is fast enough
• 1fbc1e9 Increase test timeout
• 1aae531 Unsubscribe on PostStop
• 02934e4 Merge pull request #6 from alexvaluyskiy/errorhandling
• 052323a Consumer error handling
• 919f7ea Error handling in the producer
• d100174 Merge pull request #5 from alexvaluyskiy/betterreadme
• 53db403 better readme
• c5cfa03 Merge pull request #4 from alexvaluyskiy/newsimpleconsumer
• 55e4fd6 Added MsgPack serializer
• 181d25a Fix consumer
• 539cf93 Changed Producer Flow
• c560f3a Flush messages in the producer
• 52c1568 Removed Result class
• b69ba56 Updated tests
• 9aa4e0b added tests
• c5e2023 update
• 4f0b075 fix build
• 67d2c7f initial
• 8dd8edf fix
• 7a4838a fix consumer
• 90abe9a KafkaConsumerActor
• e1d86a5 initial consumer
• f59936c fix async producer
• b1dc50b improved ProducerSettings
• 7580730 Create LICENSE
• c2addb1 fix nightly builds
• c5314ef fix publishing
• f1e3487 fix CI
• 9468ed4 added a badge
• a2a6206 appveyor
• 48449b4 added Readme

This list of changes was auto generated.

Akka.Streams.Kafka v1.0.0-rc1

1.0.0-rc1 March 02 2020

Stable release candidate of Akka.Streams.Kafka

Updated to use Akka.NET v1.4.1-rc1 and offers stable API access to Akka.Streams.Kafka.

Changes:

• 9452af9 added v1.0.0-RC1 release notes (#110)
• 7433157 upgraded to Akka.NET v1.4.1-RC1 (#109)
• cf98b8f upgrade build system to .NET Core 3.1 (#108)
• 8cc1a19 updated build system to support betas (#106)
• 300abde added v1.0.2-beta2 release notes (#105)
• b180171 Merge pull request #104 from IgorFedchenko/fix/immutable-array-init
• df75208 Fix immutable array initialization
• e3c69a2 Bump FluentAssertions from 5.10.0 to 5.10.2 (#102)
• 2c5546e Bump Microsoft.NET.Test.Sdk from 16.4.0 to 16.5.0 (#101)
• 1d437c1 PlainPartitionedSource_should_work racy test fix (#100)

See More

• 0c1035e Bump FluentAssertions from 5.9.0 to 5.10.0 (#96)
• cf853af Bump AkkaVersion from 1.4.0-beta3 to 1.4.0-beta4 (#98)
• 875b806 cleaned up the .CSPROJ files for v1.0.0-beta1 (#93)
• 5cb78a2 support-custom-nuget-tags (#92)
• 4ca03a2 Updated README and ReleaseNotes (#91)
• 575d88a Bump Confluent.Kafka from 1.2.1 to 1.2.2 (#90)
• 89c05dc Implemented transactional source (#84)
• ce80944 TransactionalFlow and TransactionalSink support (#86)
• 21fd138 Bump Microsoft.NET.Test.Sdk from 16.3.0 to 16.4.0 (#89)
• ed5dab8 FlowWithContext (#83)
• f418e7d Bump AkkaVersion from 1.4.0-beta2 to 1.4.0-beta3 (#88)
• b5e5740 Added source creation method (#81)
• ab26dfc PlainPartitionedWithOffset source (#80)
• 3633d97 Committable partitioned source (#79)
• 8e2faf7 Removed nightly feed (#78)
• 8456c4a PlainPartitionedSource (#65)
• 1b3ddf8 Bump Confluent.Kafka from 1.2.0 to 1.2.1 (#77)
• 4ea68b4 IControl implementation (#71)
• 68a63eb Bump Confluent.Kafka from 1.1.0 to 1.2.0 (#68)
• 0fcdf56 Bump Microsoft.NET.Test.Sdk from 15.9.0 to 16.3.0 (#69)
• f7b179a Bump FluentAssertions from 5.2.0 to 5.9.0 (#70)
• 146138d CommitWithMetadataSource (#64) [ #66 ]
• 669d1a1 SourceWithOffsetContext (#62)
• 4f75ed8 Implemented CommittableExternalSource (#63)
• 5f5bd87 Kafka consumer AtMostOnceSource (#60)
• 7ca3d42 close #50 - upgraded to v1.4.0-beta2 (#61)
• 0f0f31b Fix requests management (#59)
• a98057d External plain source (#56)
• 7de4f82 Added option to customize partition events by stage logic subclasses (#52)
• f508461 Added option to reuse existing container (#53)
• 3979fe4 Pause/Resume partitions on demand (#54)
• f316118 Base stage with consuming actor (#48)
• 522c7bd Added resource cleanup on start/stop testing (#47)
• 45a95ed Refactor to make consumer stages to use base classes (#45)
• 274468a Fix hard-coded groupId value for CommittableConsumerSource (#44)
• 5aa6e67 Use fixed docker image tag instead of "latest" tag (#43)
• 032e9cd Removed useless docker hosts setup (#42)
• 0e83dab Make tests pass (#41)
• c609061 Update Confluence.Kafka to 1.1.0 (#30)
• 7f05b47 have build script fail if the tests don't pass (#32)
• 55dd954 Merge pull request #31 from Aaronontheweb/fix-build-script
• 6bfd957 added TRX logging to build system
• a22f9c1 added updated Windows Release pipeline (#28)
• 342e1e9 upgraded to Akka.NET v1.3.14 (#27)
• f7538b5 Added updated v0.5.0 release notes (#26)
• 9bb6c76 Disabled PR validation for Windows Release pipeline (#25)
• 659e33f upgrade to Akka.NET v1.3.13 (#24)
• 299338a removed duplicate solution, docker-compose (#23)
• 791c48a Attribute copyright to .NET Foundation
• 61b5cda Merge pull request #22 from akkadotnet/remove-duplicate-license
• b7e266c Replacing with the Alpakka markdown license
• e562590 Merge pull request #21 from Aaronontheweb/azure-pipelines
• 90ba02d added Azure pipelines files and build scripts
• eb40b60 Merge pull request #20 from Aaronontheweb/borrow-alpakka-implementation
• 8735cb7 upgraded to .NET Core 2.0
• 45c1c77 replaced existing library wholesale with Alpakka solution
• aa26d15 Merge pull request #17 from trimsane/dev
• c69d9d4 Moving to Akka.Streams 1.3.5
• a26665a fix naming
• f51fb94 Committable Source (#12)
• 17874df Added Pause/Resume (#15)
• 032726a Use deciders for exception handling (#14)
• 86df3c6 Better logging (#13)
• c46902a Added PartitionId to ProduceRecord
• 78dfced fix consumer settings
• 464ffb1 Improved error handling (#8)
• 53a6b3c fix nuget
• 3e5e910 small tests refactoring
• b0ff8e6 Merge pull request #7 from Silv3rcircl3/dev
• 7418c49 only schedule timer if downstream is fast enough
• 1fbc1e9 Increase test timeout
• 1aae531 Unsubscribe on PostStop
• 02934e4 Merge pull request #6 from alexvaluyskiy/errorhandling
• 052323a Consumer error handling
• 919f7ea Error handling in the producer
• d100174 Merge pull request #5 from alexvaluyskiy/betterreadme
• 53db403 better readme
• c5cfa03 Merge pull request #4 from alexvaluyskiy/newsimpleconsumer
• 55e4fd6 Added MsgPack serializer
• 181d25a Fix consumer
• 539cf93 Changed Producer Flow
• c560f3a Flush messages in the producer
• 52c1568 Removed Result class
• b69ba56 Updated tests
• 9aa4e0b added tests
• c5e2023 update
• 4f0b075 fix build
• 67d2c7f initial
• 8dd8edf fix
• 7a4838a fix consumer
• 90abe9a KafkaConsumerActor
• e1d86a5 initial consumer
• f59936c fix async producer
• b1dc50b improved ProducerSettings
• 7580730 Create LICENSE
• c2addb1 fix nightly builds
• c5314ef fix publishing
• f1e3487 fix CI
• 9468ed4 added a badge
• a2a6206 appveyor
• 48449b4 added Readme

This list of changes was auto generated.

Akka.Streams.Kafka v1.0.0-beta2

1.0.0-beta2 February 18 2020

Second beta release of Akka.Streams.Kafka

This release builds upon the work of the 1.0.0-beta1 released last year, but with some improvements and changes:

• Updated to use Akka.NET v1.4.0-beta4;
• Bugfix: InvalidOperationException

Changes:

• 8cc1a19 updated build system to support betas (#106)
• 300abde added v1.0.2-beta2 release notes (#105)
• b180171 Merge pull request #104 from IgorFedchenko/fix/immutable-array-init
• df75208 Fix immutable array initialization
• e3c69a2 Bump FluentAssertions from 5.10.0 to 5.10.2 (#102)
• 2c5546e Bump Microsoft.NET.Test.Sdk from 16.4.0 to 16.5.0 (#101)
• 1d437c1 PlainPartitionedSource_should_work racy test fix (#100)
• 0c1035e Bump FluentAssertions from 5.9.0 to 5.10.0 (#96)
• cf853af Bump AkkaVersion from 1.4.0-beta3 to 1.4.0-beta4 (#98)
• 875b806 cleaned up the .CSPROJ files for v1.0.0-beta1 (#93)

See More

• 5cb78a2 support-custom-nuget-tags (#92)
• 4ca03a2 Updated README and ReleaseNotes (#91)
• 575d88a Bump Confluent.Kafka from 1.2.1 to 1.2.2 (#90)
• 89c05dc Implemented transactional source (#84)
• ce80944 TransactionalFlow and TransactionalSink support (#86)
• 21fd138 Bump Microsoft.NET.Test.Sdk from 16.3.0 to 16.4.0 (#89)
• ed5dab8 FlowWithContext (#83)
• f418e7d Bump AkkaVersion from 1.4.0-beta2 to 1.4.0-beta3 (#88)
• b5e5740 Added source creation method (#81)
• ab26dfc PlainPartitionedWithOffset source (#80)
• 3633d97 Committable partitioned source (#79)
• 8e2faf7 Removed nightly feed (#78)
• 8456c4a PlainPartitionedSource (#65)
• 1b3ddf8 Bump Confluent.Kafka from 1.2.0 to 1.2.1 (#77)
• 4ea68b4 IControl implementation (#71)
• 68a63eb Bump Confluent.Kafka from 1.1.0 to 1.2.0 (#68)
• 0fcdf56 Bump Microsoft.NET.Test.Sdk from 15.9.0 to 16.3.0 (#69)
• f7b179a Bump FluentAssertions from 5.2.0 to 5.9.0 (#70)
• 146138d CommitWithMetadataSource (#64) [ #66 ]
• 669d1a1 SourceWithOffsetContext (#62)
• 4f75ed8 Implemented CommittableExternalSource (#63)
• 5f5bd87 Kafka consumer AtMostOnceSource (#60)
• 7ca3d42 close #50 - upgraded to v1.4.0-beta2 (#61)
• 0f0f31b Fix requests management (#59)
• a98057d External plain source (#56)
• 7de4f82 Added option to customize partition events by stage logic subclasses (#52)
• f508461 Added option to reuse existing container (#53)
• 3979fe4 Pause/Resume partitions on demand (#54)
• f316118 Base stage with consuming actor (#48)
• 522c7bd Added resource cleanup on start/stop testing (#47)
• 45a95ed Refactor to make consumer stages to use base classes (#45)
• 274468a Fix hard-coded groupId value for CommittableConsumerSource (#44)
• 5aa6e67 Use fixed docker image tag instead of "latest" tag (#43)
• 032e9cd Removed useless docker hosts setup (#42)
• 0e83dab Make tests pass (#41)
• c609061 Update Confluence.Kafka to 1.1.0 (#30)
• 7f05b47 have build script fail if the tests don't pass (#32)
• 55dd954 Merge pull request #31 from Aaronontheweb/fix-build-script
• 6bfd957 added TRX logging to build system
• a22f9c1 added updated Windows Release pipeline (#28)
• 342e1e9 upgraded to Akka.NET v1.3.14 (#27)
• f7538b5 Added updated v0.5.0 release notes (#26)
• 9bb6c76 Disabled PR validation for Windows Release pipeline (#25)
• 659e33f upgrade to Akka.NET v1.3.13 (#24)
• 299338a removed duplicate solution, docker-compose (#23)
• 791c48a Attribute copyright to .NET Foundation
• 61b5cda Merge pull request #22 from akkadotnet/remove-duplicate-license
• b7e266c Replacing with the Alpakka markdown license
• e562590 Merge pull request #21 from Aaronontheweb/azure-pipelines
• 90ba02d added Azure pipelines files and build scripts
• eb40b60 Merge pull request #20 from Aaronontheweb/borrow-alpakka-implementation
• 8735cb7 upgraded to .NET Core 2.0
• 45c1c77 replaced existing library wholesale with Alpakka solution
• aa26d15 Merge pull request #17 from trimsane/dev
• c69d9d4 Moving to Akka.Streams 1.3.5
• a26665a fix naming
• f51fb94 Committable Source (#12)
• 17874df Added Pause/Resume (#15)
• 032726a Use deciders for exception handling (#14)
• 86df3c6 Better logging (#13)
• c46902a Added PartitionId to ProduceRecord
• 78dfced fix consumer settings
• 464ffb1 Improved error handling (#8)
• 53a6b3c fix nuget
• 3e5e910 small tests refactoring
• b0ff8e6 Merge pull request #7 from Silv3rcircl3/dev
• 7418c49 only schedule timer if downstream is fast enough
• 1fbc1e9 Increase test timeout
• 1aae531 Unsubscribe on PostStop
• 02934e4 Merge pull request #6 from alexvaluyskiy/errorhandling
• 052323a Consumer error handling
• 919f7ea Error handling in the producer
• d100174 Merge pull request #5 from alexvaluyskiy/betterreadme
• 53db403 better readme
• c5cfa03 Merge pull request #4 from alexvaluyskiy/newsimpleconsumer
• 55e4fd6 Added MsgPack serializer
• 181d25a Fix consumer
• 539cf93 Changed Producer Flow
• c560f3a Flush messages in the producer
• 52c1568 Removed Result class
• b69ba56 Updated tests
• 9aa4e0b added tests
• c5e2023 update
• 4f0b075 fix build
• 67d2c7f initial
• 8dd8edf fix
• 7a4838a fix consumer
• 90abe9a KafkaConsumerActor
• e1d86a5 initial consumer
• f59936c fix async producer
• b1dc50b improved ProducerSettings
• 7580730 Create LICENSE
• c2addb1 fix nightly builds
• c5314ef fix publishing
• f1e3487 fix CI
• 9468ed4 added a badge
• a2a6206 appveyor
• 48449b4 added Readme

This list of changes was auto generated.