reactive-data-flow-systems

This repository is containing reactive data-flow systems integration using kafka, tailable mongodb webflux api.

build, run and test

./gradlew                                                # or ./mwnw
java - jar ./kafka/build/libs/*.jar                      # or java - jar ./kafka/target/*.jar
java - jar ./reactive-dataflow-api/build/libs/*.jar       # or java - jar ./reactive-dataflow-api/target/*.jar
java - jar ./reactive-dataflow-processor/build/libs/*.jar # or java - jar ./reactive-dataflow-processor/target/*.jar
curl localhost:8083 &
http :8082 body=message1
curl localhost:8083 &
http :8082 body=message2
http :8082 body=message3
killall -9 java curl

links:

1. Oliver Gierke Spring data talk: Refactoring to a System of Systems