Note: This project is based on the flink-tangle-source library. This is a proof of concept and should not be used in production environments. Feel free to contribute, so that it eventually becomes production ready.
This project has a few tangle streaming examples in Flink.
You need to install java >= 8 & sbt, before you can execute the examples.
Since this library is not production ready, you need to build & publish the dependencies locally. You can find the description about the process in the repositories:
If the dependencies are available, you can run the example in the following way:
sbt runSBT will ask you which application you want to run. Just select the application you want to run.
TangleBeat has a list of public tangle ZMQ server. Just pick one and change the application.conf in src/main/resources