Quixstreams

This is the first alpha release of the new Quix Streams 2.0.
It's a complete rewrite, providing a different API to work with streaming data in Python.


What's Changed
Introduced Streaming DataFrames - a primary API to define the processing pipeline
1. It provides a `pandas.DataFrame`-like API to structure the message transformations.
For the full description of `StreamingDataFrame` API please see [StreamingDataFrame: Detailed Overview](https://github.com/quixio/quix-streams/blob/main/src/StreamingDataFrames/docs/streamingdataframe.md)

2. It supports stateful operations backed by RocksDB state storage. The details regarding work with state are outlined here - [Stateful Processing](https://github.com/quixio/quix-streams/blob/main/src/StreamingDataFrames/docs/stateful-processing.md)

3. It supports different message serialization formats like strings, integers, doubles, JSON and Quix formats.
Detailed overview of serialization in 2.0 can be found here - [Serialization](https://github.com/quixio/quix-streams/blob/main/src/StreamingDataFrames/docs/serialization.md)

Removed a dependency on .NET
The 2.0 version doesn't depend on .NET anymore and is pure Python.
It makes the library code more stable, safe, and easier to maintain and update.

New
* Create leading edge buffer where tag is not part of the key by peter-quix in https://github.com/quixio/quix-streams/pull/180

Bugfix
* Python app should subscribe by default similarly to C by peter-quix in https://github.com/quixio/quix-streams/pull/190

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v0.5.6...v0.5.7

Improvements

* Reduce debug log verbosity when broker connections are reaped due to inactivity or other by peter-quix in https://github.com/quixio/quix-streams/pull/184
* Add subscribe/unsubscribe to topics by peter-quix in https://github.com/quixio/quix-streams/pull/186
* Improved file based storage resiliency and speed by peter-quix in https://github.com/quixio/quix-streams/pull/185

Bugfixes

* infinity and NaN no longer cause exception in timeseries data. Was introduced in 0.5.5 via https://github.com/quixio/quix-streams/commit/3d6a24454d850d0d8d143615533d6889b7366ac8 peter-quix in https://github.com/quixio/quix-streams/pull/185


**Full Changelog**: https://github.com/quixio/quix-streams/compare/v0.5.5...v0.5.6

New
* Add scalar state type by harisbotic in https://github.com/quixio/quix-streams/pull/137
* Implement LeadingEdgeBuffer by harisbotic in https://github.com/quixio/quix-streams/pull/146 and https://github.com/quixio/quix-streams/pull/154

Improvements
* C Performance improvements by peter-quix in https://github.com/quixio/quix-streams/pull/141
* Expand coverage of idle connection reap message check for consumer by peter-quix in https://github.com/quixio/quix-streams/pull/165
* Use client.id when using QuixStreamingClient to connect to Confluent Cloud Kafka (155) by jordivicedo in https://github.com/quixio/quix-streams/pull/156

Bug fixes
* Handle nulls better in State store by peter-quix in https://github.com/quixio/quix-streams/pull/159
* Ensure last message is flushed on dispose by peter-quix in https://github.com/quixio/quix-streams/pull/160
* Fix python state segfaults by peter-quix in https://github.com/quixio/quix-streams/pull/163
* Fix reporting of available brokers in producer by peter-quix in https://github.com/quixio/quix-streams/pull/164
* Revert to empty parameter when missing rather than exception by peter-quix in https://github.com/quixio/quix-streams/pull/167
* Malloc/memleak fixes by peter-quix in https://github.com/quixio/quix-streams/pull/169

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

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v0.5.4...v0.5.5

What is new
- Added Flush to stream. This lets you send all pending messages without having to close the stream or calling flush on multiple stream components. (112)
- Apple silicon builds are now available for python (and back-ported to 0.5.3) (122, build changes not tied to code yet)
- First Stream state version implemented using existing disk storage. (119) More to come (105, 104, etc, make your voice heard). See docs in [git](https://github.com/quixio/quix-streams/blob/v0.5.4/docs/state-management.md), or better rendered on our [docs site](https://quix.io/docs/client-library/state-management.html#state-management_1). For now this is still considered experimental feature.
- Non-QuixStreams messages are now raised as events. More support on this coming, but for now JSON messages should be easier to consume. (120)
- Added interfaces to some of the clients, mainly to enable mocking for your tests. (131 )
- TimeseriesDataTimestamp can now be written to the stream. This mean individual rows can be published without converting it to TimeseriesData first. (130)

Changes/Improvements
- Sending null tag or value is no longer raising exception, instead treated as removal. (132)

Bugfixes
- Some native objects used in python were causing memory leak. This is now fixed.

**Full Changelog**: https://github.com/quixio/quix-streams/compare/v0.5.3...v0.5.4