v3.6.0
What's Changed
Main Changes
⚠️ Switch to "range"
assignor strategy from "cooperative-sticky"
Due to discovered issues with the "cooperative-sticky"
assignment strategy, commits made during the rebalancing phase were failing.
To avoid that, we changed the partition assignor to "range"
which doesn't have such issues.
Note that "range"
assignor is enforced for consumers used by Application
, but it can be overridden for consumers created via app.get_consumer()
API.
❗How to update:
Since "cooperative-sticky"
and "range"
strategies must not be mixed, all consumers in the group must first leave the group, and then rejoin it after upgrading the application to Quix Streams v3.6.0
.
For more details, see #705 and #712
Other Changes
- Source: background file downloads for FileSource by @tim-quix in #670
- Fix lateness warnings in Windows by @daniil-quix in #700
- mypy: make quixstreams.core.* pass type checks by @quentin-quix in #685
- mypy: ensure default are set in overloaded methods by @quentin-quix in #698
- mypy: make quixstreams.dataframe.* pass type checks by @quentin-quix in #695
Docs
- Update mkdocs.yml by @gwaramadze in #703
- Update Documentation by @github-actions in #696
- Update Documentation by @github-actions in #699
- Bump version to 3.6.0 by @daniil-quix in #711
Full Changelog: v3.5.0...v3.6.0