You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
*v1.5.39 is a major update for Akka.Streams.Kafka*
2
4
3
-
*[Upgraded to Akka.NET v1.5.38](https://github.com/akkadotnet/akka.net/releases/tag/1.5.38)
4
5
*[Resolved: System.ArgumentException: Unexpected records polled potentially thrown during a rebalance](https://github.com/akkadotnet/Akka.Streams.Kafka/issues/415)
6
+
*[Expose `ConsumerSettings.MaxPollRecords`](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/453) available so users can performance-tune how many records to fetch during polling.
7
+
*[Change `Assign` and `AssignWithOffsets` to use `IncrementalAssign`](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/455) - prevents `Offset` resets for users running `ManualSubscription`s
8
+
*[Refactor `SubSourceStageLogic`; filter messages from revoked partitions in partitioned stream sources](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/452)
9
+
*[Filter out buffered records from recently revoked partitions](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/450)
<PackageReleaseNotes>[Upgraded to Akka.NET v1.5.38](https://github.com/akkadotnet/akka.net/releases/tag/1.5.38)
5
-
[Resolved: System.ArgumentException: Unexpected records polled potentially thrown during a rebalance](https://github.com/akkadotnet/Akka.Streams.Kafka/issues/415)</PackageReleaseNotes>
3
+
<VersionPrefix>1.5.39</VersionPrefix>
4
+
<PackageReleaseNotes>v1.5.39 is a major update for Akka.Streams.Kafka*
5
+
[Resolved: System.ArgumentException: Unexpected records polled potentially thrown during a rebalance](https://github.com/akkadotnet/Akka.Streams.Kafka/issues/415)
6
+
[Expose `ConsumerSettings.MaxPollRecords`](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/453) available so users can performance-tune how many records to fetch during polling.
7
+
[Change `Assign` and `AssignWithOffsets` to use `IncrementalAssign`](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/455) - prevents `Offset` resets for users running `ManualSubscription`s
8
+
[Refactor `SubSourceStageLogic`; filter messages from revoked partitions in partitioned stream sources](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/452)
9
+
[Filter out buffered records from recently revoked partitions](https://github.com/akkadotnet/Akka.Streams.Kafka/pull/450)
0 commit comments