StreamPipes enables flexible modeling of stream processing pipelines by providing a graphical modeling editor on top of existing stream processing frameworks.
It leverages non-technical users to quickly define and execute processing pipelines based on an easily extensible toolbox of data sources, data processors and data sinks. StreamPipes has an exchangeable runtime execution layer and executes pipelines using one of the provided wrappers, e.g., for Apache Flink or Apache Kafka Streams.
Learn more about StreamPipes at https://www.streampipes.org/
Read the full documentation at https://docs.streampipes.org
It's easy to get started:
docker-compose.yml
file from https://www.github.com/streampipes/preview-dockerYou can easily add your own data streams, processors or sinks.
Check our developer guide at https://docs.streampipes.org/developer_guide/introduction
We welcome contributions to StreamPipes. If you are interested in contributing to StreamPipes, let us know!
We'd love to hear your feedback! Contact us at feedback@streampipes.org