v2.11.0
What's Changed
[New] Source API and built-in Sources
With the new Sources API, you can stream data from any data source to a Kafka topic and process it with Streaming DataFrames in the same application.
You can either use one of the built-in sources (e.g. KafkaReplicatorSource, CSVSource, QuixEnvironmentSource) or create a custom one.
To learn more about Sources, please see the Sources documentation
PRs: #420, #448, #490 , #494 , #495, #498, #506
Dependencies updates
- Bump testcontainers from 4.8.0 to 4.8.1 by @dependabot in #492
- Update pydantic requirement from <2.9,>=2.7 to >=2.7,<2.10 by @dependabot in #491
- Update pydantic-settings requirement from <2.5,>=2.3 to >=2.3,<2.6 by @dependabot in #500
Documentation updates
- Fix typo in FixedTimeWindowDefinition.reduce docstring by @gwaramadze in #501
- Fix documentation link by @gwaramadze in #478
- Update README.md by @daniil-quix in #479
Other changes
- Add Conda configuration by @gwaramadze in #482
- Optimize get_window_ranges function by @gwaramadze in #489
Full Changelog: v2.10.0...v2.11.0