Akka.Streams.Kafka v1.5.39-beta1

1.5.39-beta1 March 13th 2025

v1.5.39 is a major update for Akka.Streams.Kafka

• Resolved: System.ArgumentException: Unexpected records polled potentially thrown during a rebalance
• Expose ConsumerSettings.MaxPollRecords available so users can performance-tune how many records to fetch during polling.
• Change Assign and AssignWithOffsets to use IncrementalAssign - prevents Offset resets for users running ManualSubscriptions
• Refactor SubSourceStageLogic; filter messages from revoked partitions in partitioned stream sources
• Filter out buffered records from recently revoked partitions
• Enable nullability

Changes:

• 1c72293 Added v1.5.39-beta1 release notes (#456)
• 359aa54 Resolve ArgumentException upon partition re-assignment (#454) [ #415 ]
• 71a6606 Change Assign and AssignWithOffsets to use IncrementalAssign (#455)
• 97fb44a Add RebalanceExtTests for testing partitioned message loss on rebalance (#453)
• aead3e4 Refactor SubSourceStageLogic; filter messages from revoked partitions in partitioned stream sources (#452)
• 215a232 Rewrite RebalanceIntegrationTests; filter out buffered records from recently revoked partitions (#450)
• 573437d Enable nullability (#449)
• a39e933 [WIP] fix nullability / build warnings (#448)

This list of changes was auto generated.