docker-compose -f kafka-docker.yml up
This service is responsive for pushing a streaming data from meetup stream API into Kafka. I have used Akka-Http single websocket and Alpakka-Kafka for ingestion rsvp into Kafka.
sbt "project ingestion" run
This service is responsible for performing business logic on incoming kafka stream. After performing business logic, I am storing output into external data source.
sbt "project" test
sbt "project etl" run
Note: Remove ing_meetup directory if you get any error.
This service is responsible for below use cases:
- Coupling the implementation to the stream
- Calculating the most popular meetup locations in the world
- Show trending topics by country
sbt "project api" run
This app responsible for display live stream rsvp, most popular meetups in the world and trending topics of the country.
cd app
npm install
npm start
Open http://localhost:8000/ on browser