Quixstreams

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

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

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

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

What's Changed

Bugfixes
* Updates to work with Redpanda brokers via Quix platform by daniil-quix in https://github.com/quixio/quix-streams/pull/283
* Fix RocksDB does not retry opening if it's locked by another process by harisbotic in https://github.com/quixio/quix-streams/pull/272
* Add name property to window s by harisbotic in https://github.com/quixio/quix-streams/pull/277

Docs
* Add docs about windows by daniil-quix in https://github.com/quixio/quix-streams/pull/274
* Update docs config by daniil-quix in https://github.com/quixio/quix-streams/pull/276
* Fix windows docs by daniil-quix in https://github.com/quixio/quix-streams/pull/278
* Update windows docs by stereosky in https://github.com/quixio/quix-streams/pull/279
* Update readme by daniil-quix in https://github.com/quixio/quix-streams/pull/284
* add a line to the readme about sliding windows by tim-quix in https://github.com/quixio/quix-streams/pull/285

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

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.2.0a...v2.2.1a

What's Changed

Added Windowed Aggregations

- Implemented two types of time-based windows:
- **Tumbling windows** slice time into even non-overlapping periods.
Example: [0, 10), [10, 20), [20,30)

- **Hopping windows** slice time into even overlapping periods with a fixed step.
Example: [0,10), [1, 11), [2, 12)
- **Support for various aggregation functions**: `sum`, `count`, `mean`, `min`, `max`, `reduce`
- **Two modes of emitting aggregated results:**
- **final** - to emit results when the window is closed
- **current** - to emit results for each incoming message as it's processed
- **Support for out-of-order processing**

Find more about Windowed Aggregations in [the docs](https://github.com/quixio/quix-streams/blob/main/docs/windowing.md)


**Full Changelog**: https://github.com/quixio/quix-streams/compare/v2.1.4a...v2.2.0a