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: