v0.29.1

pathwaycom/pathwayv0.29.1Feb 16, 2026by github-actions[bot]

AI Summary

This release adds OAUTHBEARER authentication support for Kafka connectors, introduces a new output_table_type parameter for MongoDB writes with snapshot and stream modes, enables automatic worker scaling based on pipeline load, and adds TLS configuration support for PostgreSQL writes.

Key Highlights

  • Kafka connectors now support OAUTHBEARER authentication
  • MongoDB write connector supports output_table_type with snapshot and stream_of_changes modes
  • Workers can automatically scale up/down based on pipeline load with configurable monitoring window
  • PostgreSQL write connector now supports TLS configuration via sslmode and sslrootcert
  • pw.xpacks.connectors.read now retries initial connection requests

New Features

  • OAUTHBEARER authentication for pw.io.kafka.read and pw.io.kafka.write
  • output_table_type parameter for pw.io.mongodb.write (stream_of_changes/snapshot modes)
  • Automatic worker scaling with worker_scaling_enabled and workload_tracking_window_ms
  • TLS configuration support for pw.io.postgres.write

Full Release Notes

### Added
- `pw.io.kafka.read` and `pw.io.kafka.write` connectors now support OAUTHBEARER authentication.
- `pw.io.mongodb.write` connector now supports an `output_table_type` parameter with two modes: `stream_of_changes` (default) and `snapshot`. In `snapshot` mode, the connector maintains the current state of the Pathway table in MongoDB using the `_id` field as the primary key, while `stream_of_changes` preserves the existing behavior by writing all events with `time` and `diff` flags to reflect transactional minibatches and the nature of each change.
- Workers can now automatically scale up or down based on pipeline load, using a configurable monitoring window. This feature requires persistence to be enabled and can be configured via `worker_scaling_enabled` and `workload_tracking_window_ms` in `pw.persistence.Config`. Please refer to the tutorial for more details.
- `pw.io.postgres.write` now properly supports TLS configuration via `sslmode` and `sslrootcert` connection string parameters.

### Changed
- `pw.xpacks.connectors.read` now retries initial connection requests.