Starstruk Logo MarkStarstruk

v0.29.1

trycompai/compv0.29.1Feb 16, 2026by github-actions[bot]

AI Summary

Adds OAuthBearer authentication for Kafka connectors, MongoDB snapshot mode, auto-scaling workers, and TLS support for Postgres.

Key Highlights

  • Kafka OAUTHBEARER authentication
  • MongoDB snapshot mode
  • Worker auto-scaling
  • Postgres TLS configuration

New Features

  • Kafka OAUTHBEARER auth
  • MongoDB snapshot mode
  • Worker auto-scaling
  • Postgres TLS

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.