v0.15.4

pathwaycom/pathwayv0.15.4Nov 18, 2024by github-actions[bot]

AI Summary

Adds NATS connectors and Kafka timestamp reading, ensuring full sync for Postgres tables.

Key Highlights

Added `pw.io.nats.read` and `pw.io.nats.write` methods.
Kafka read now supports reading entries starting from a specified timestamp.
Postgres write_snapshot keeps the Postgres table fully in sync.

New Features

`pw.io.nats.read`.
`pw.io.nats.write`.
`pw.io.kafka.read` now supports reading entries starting from a specified timestamp.

Full Release Notes

### Added
- `pw.io.kafka.read` now supports reading entries starting from a specified timestamp.
- `pw.io.nats.read` and `pw.io.nats.write` methods for reading from and writing Pathway tables to NATS.

### Changed
- `pw.Table.diff` now supports setting `instance` parameter that allows computing differences for multiple groups.
- `pw.io.postgres.write_snapshot` now keeps the Postgres table fully in sync with the current state of the table in Pathway. This means that if an entry is deleted in Pathway, the same entry will also be deleted from the Postgres table managed by the output connector.

### Fixed
- `pw.PyObjectWrapper` is now picklable.