pathway
pathway copied to clipboard
Extend NATS connector to support JetStream
Is your feature request related to a problem? Please describe. Currently, Pathway supports input and output with NATS. Often, when NATS is used, the JetStream extension is enabled to add durability for the messaging actor.
This issue proposes to add JetStream support and ensure that JetStream works properly with Pathway pipelines.
Describe the solution you'd like
Pathway uses an async-nats crate for the connector implementation. This crate already has a jetstream submodule that can provide the necessary support.