I am really happy to share a project that I've been working on over the past few months: River-Kt. It's a collection of extension functions and enterprise integrations for Kotlin's Flow and coroutines.
Drawing inspiration from Alpakka and Apache Camel, River-Kt leverages the features of Flow to provide an easy way to build integrations across multiple protocols and services, such as HTTP, AWS (SQS, SNS, S3, etc.), AMQP, Debezium, JSON, Files, and others.
Please note that River-Kt is currently in the alpha stage, which means that certain aspects may change in the near future. Some connectors might not be stable yet, and the project is still gathering feedback before an official initial release.
While the project currently lacks comprehensive "end-to-end" documentation, the existing kdocs are relatively informative. If you're familiar with the basics of Flow and reactive streams, you'll find them to be a helpful starting point.
I would greatly appreciate any feedback you may have on this project, including suggestions for improvements or fixes.
You can find the GitHub repository here: https://github.com/River-Kt/river
And the website with the kdoc is available at: https://www.river-kt.com/
Thank you for your time and consideration!