reactive-data-flow-with-kafla-and-tailable-mongodb

This repository contains modern approach to build webapp these days: here is and example of webflux application with reactive data flow for @Tailable capped collection of embedded mongodb and embedded kafka message broker. application is fully asynchronous and non blocking

build and start

# gradle                   # or maven
bash ./gradlew             # or `bash ./mvnw`
java -jar build/libs/*.jar # or `java -jar target/*.jar`

connect online clients and watch

curl 127.0.0.1:8080
open http://127.0.0.1:8080 # browser

save data via @Tailable mongodb collection

http :8080/api/v1/save-message body=mongodb

send message for saving via kafka broker

http :8080/api/v1/send-message body=kafka