This project demonstrates a data streaming pipeline using Apache Flink, RabbitMQ, and PostgreSQL.
The pipeline reads events from RabbitMQ, processes them with Apache Flink, and stores the results in a PostgreSQL database.
-
Notifications
You must be signed in to change notification settings - Fork 0
Sharath-majjigi/apache-flink-rabbitMQ-pipeline
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
A pipeline that streams live events from rabbitMQ and aggreagtes the events by session_duration (A field in event) and store the results in postgresDB
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published