v0.0.43
New:
- Added support for Apache Hudi writing.
- Added support for schema registry deserialisation from kafka input
- Added Hive Docker
- Added E2E example for
MySQL -> Debezium -> kafka -> Hudi + Hive
Improvements:
- Support kafka topic pattern
- Support writing full dataframes to influxDB with all columns as tags
- Add support for watermark in streaming metrics
- Support streaming for all writers using batchMode
Fixes
- Fixed hive implementation
- Use Hive metastore in E2E instead of MySQL DB
- Support tests without mocks
- Multiple bug fixes