Real Time Chat App
-
Updated
Sep 26, 2023 - HTML
Real Time Chat App
An end-to-end data engineering pipeline that fetches real-time YouTube analytics and streams them through Kafka for processing with ksqlDB. The processed analytics data is then sent to Telegram for real-time notifications.
change data capture (CDC) to ingest binlogs from the source database, process them, and write them to the target database correctly, completely, and instantly in real time. using docker-compose,Kafka connectors (debezium, jdbc sink), compute engine, cloud sql, database mysql, confluent.
Starter code for the ksqlDB workshop. This workshop explains how to integrate ksqlDB with an external data source (Elasticsearch) to build Driver Location Tracking & Monitoring app and use streaming SQL engine for Apache Kafka.
Collect & stream data, notify user on Telegram
This project goals is to implement streams using ksqldb while connecting to postgreSQL database with jdbc-connector.
Add a description, image, and links to the ksqldb topic page so that developers can more easily learn about it.
To associate your repository with the ksqldb topic, visit your repo's landing page and select "manage topics."