Feat. JetStream Support for Sink

synadia-io / flink-connector-nats

Nats Java Flink Connector

Apache License 2.0

10 stars 2 forks source link

Feat. JetStream Support for Sink #5

Closed somratdutta closed 1 week ago

somratdutta commented 10 months ago

We have added support for NATS JetStream for Source. Also added is a test-case for the Source class. We are open to feedback and actively working on to improve the current state of this project.

somratdutta commented 9 months ago

I am planning to close the Sink PR for now to make it convenient for you to review the Source PR first and not overwhelm you. @scottf