quix-streams
quix-streams copied to clipboard
quixio
Python stream processing for Kafka
# Problem The example of the custom timestamp extractor [here](https://quix.io/docs/quix-streams/windowing.html#extracting-timestamps-from-messages) doesn't have all the required imports, which makes it hard to copy them to the code. The code samples should...
This is the PR with the autogenerated documentation
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
Trigger some type checking tool (like mypy, pylance, etc) during "Lint" step
After merging #420 , implement a Source that accepts a callable and returns an iterable to be used for testing. Example: ``` from quixstreams import Application from quixstreams.sources.iterable import IterableSource...
Updates the requirements on [confluent-kafka](https://github.com/confluentinc/confluent-kafka-python) to permit the latest version. Release notes Sourced from confluent-kafka's releases. v2.5.3 confluent-kafka-python v2.5.3 v2.5.3 is a maintenance release with the following fixes and enhancements:...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}