Machine a stream processing library with opentelemetry support, dynamic processing with yaegi, and a clean interface

I built this library in order to quickly build stream processors with tracing, serialization support, and a command to generate the projects.

The API is now stable and inface implementations for kafka, SQS, redis streams and google pub/sub are provided out of the box.

Let me know your thoughts and leave a star if you like it!

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.