quix-streams
quix-streams copied to clipboard
quixio
Python stream processing for Kafka
**Tell us about the bug** Topic param definition does not match its usage. As part of this change: https://github.com/quixio/quix-streams/pull/292, the attribute was changed from Optional to required, but the corresponding...
There were some spacing issues with bullets in the tutorials causing them to not render correctly in the website version of the doc. Adding spaces fixes them. Also minor language...
additional timestamp checks for groupby on the dataframe level
Added timeout arguments across all REST API calls and provided a way to set them from the `Application` level. There are 2 options, `request_timeout` and `topic_create_timeout` (which is more of...
# Why? To provide SASL and SSL authentication configs, users need to do it twice for Producer and Consumer via `producer_extra_config` and `consumer_extra_config`. It may lead to duplicating the same...
# Why? Currently, when the application recovers from the changelog topic, it writes every state update to the rocksdb. It's not very efficient and can lead to longer recovery times....
Track test coverage with `pytest` and add a badge displaying coverage for the latest `main` branch.
To improve the code quality, trigger [Ruff](https://docs.astral.sh/ruff/) linter from the pre-commit hooks and CI/CD. # What to do 1. Add Ruff config to `pyproject.toml`. 2. Extend the default Ruff rules...