Quixstreams

Latest version: v2.4.2

Safety actively analyzes 624134 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 4

2.4.2

What's Changed

* Fix handling of topics created outside of Quix Cloud by tim-quix in https://github.com/quixio/quix-streams/pull/338
* Add clearer error messages for invalid SDF column name references by tim-quix in https://github.com/quixio/quix-streams/pull/322
* Better handling of topic creation errors in Quix Cloud by tim-quix in https://github.com/quixio/quix-streams/pull/337
* Use pyproject.toml instead of setup.cfg by tim-quix in https://github.com/quixio/quix-streams/pull/339

* Update docs by tbedford https://github.com/quixio/quix-streams/pull/325 https://github.com/quixio/quix-streams/pull/331
* Update README by stereosky https://github.com/quixio/quix-streams/pull/332 https://github.com/quixio/quix-streams/pull/335

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.4.1...v2.4.2

2.4.1

What's Changed
* Fix 404s in README by daniil-quix in https://github.com/quixio/quix-streams/pull/328
* hotfix bug around undefined workspace id for Quix API class by tim-quix in https://github.com/quixio/quix-streams/pull/329


**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.4.0...v2.4.1

2.4.0

What's Changed
Features
Unified `Application` and `Application.Quix()` by tim-quix in https://github.com/quixio/quix-streams/pull/313
In previous versions, to connect to Quix Cloud brokers you needed to use a separate factory method to create an Application - `Application.Quix()`.
Due to that, developing apps with local Kafka and deploying them to Quix Cloud required additional code changes.
In this release, we improved that, and you now may use a single `Application()` class with different settings to connect both to Quix Cloud and standalone Kafka brokers.

See more about working with Quix Cloud in the docs - [Connecting to Quix Cloud](https://quix.io/docs/quix-streams/quix-platform.html)


Enhancements

* Improved Quix API error handling by tim-quix in https://github.com/quixio/quix-streams/pull/320
* Adjust producer flush docstring by tim-quix in https://github.com/quixio/quix-streams/pull/321
* New docs by daniil-quix in https://github.com/quixio/quix-streams/pull/315
* Update black formatter version by daniil-quix in https://github.com/quixio/quix-streams/pull/316


**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.3.3...v2.4.0

2.3.3

What's Changed
* Example Bugfix: Do not override state input on each update by alexmorley in https://github.com/quixio/quix-streams/pull/310
* Fix default replication_factor for topics created by Quix apps by daniil-quix in https://github.com/quixio/quix-streams/pull/317

New Contributors
* alexmorley made their first contribution in https://github.com/quixio/quix-streams/pull/310

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.3.2...v2.3.3

2.3.2

What's Changed

Features
* Support GZIP compression of messages formatted in Quix formats by peter-quix in https://github.com/quixio/quix-streams/pull/305

Fixes
* Fix type hints and code completion by tim-quix in https://github.com/quixio/quix-streams/pull/292
* Allow processing of non-dict values in `StreamingDataFrame` by harisbotic in https://github.com/quixio/quix-streams/pull/307
* Skip processing of messages with `None` keys in windowed aggregations by harisbotic in https://github.com/quixio/quix-streams/pull/306

Enhancements
* Set the default value of consumer group to `'quixstreams-default'` in `Application` by harisbotic in https://github.com/quixio/quix-streams/pull/299
* Set a default value for `Quix__Portal__Api` env variable in Quix apps by harisbotic in https://github.com/quixio/quix-streams/pull/294
* Raise exception on` __bool__` checks in `StreamingDataFrame` by tim-quix in https://github.com/quixio/quix-streams/pull/295
* Don't set `ssl.endpoint.identification.algorithm` anymore for Quix apps by harisbotic in https://github.com/quixio/quix-streams/pull/293
* Update docs by stereosky in https://github.com/quixio/quix-streams/pull/300




**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.3.1...v2.3.2

2.3.1

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](https://quix.io/docs/quix-streams/v2-0-latest/stateful-processing.html#fault-tolerance-recovery)

- `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](https://quix.io/docs/quix-streams/v2-0-latest/api-reference/application.html#applicationtopic)

- 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**: https://github.com/quixio/quix-streams/compare/v2.2.1a...v2.3.1

Page 1 of 4

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.