Skip to content

v2.3.1
Compare
Choose a tag to compare
@daniil-quix daniil-quix released this 15 Feb 17:27
· 75 commits to main since this release
v2.3.1
f9167c5
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Learn about vigilant mode.

What's Changed

  • Added support for Changelog topics

    • Changelog topics provide fault tolerance capabilities to state stores.
      Each state store now has a corresponding changelog topic to keep track of the state updates in Kafka.
    • Changelog topics are enabled by default and can be disabled.
    • See more about changelog topics in the docs

  • Application.run() class now verifies that topics exist before starting the application.
    If topics don't exist, the Application instance will try to create them automatically if auto_create_topics is set to True (default).
    The topic parameters can also be specified, see more in the docs

  • This is the first non-alpha release of Quix Streams v2. It can now be installed from pip without the --pre flag.

Breaking changes

  • The partition assignment strategy is now always set to cooperative-sticky and cannot be configured anymore because the consumer relies on the incremental_assign() API for recovery.
    Previously, the assignment strategy was set to range by default, and range is a non-cooperative strategy.
    Since cooperative and non-cooperative (eager) strategies must not be mixed, all consumers in the group must first leave the group, and then join it again after upgrading the application to this version.

Full Changelog: v2.2.1a...v2.3.1

Assets 2
Loading