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!