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.
This project goals is to implement streams using ksqldb while connecting to postgreSQL database with jdbc-connector.
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
Real Time Chat App
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."