🏥 A simple healthcheck wrapper to monitor Kafka Connect.
-
Updated
Jun 4, 2021 - Python
🏥 A simple healthcheck wrapper to monitor Kafka Connect.
Guardian for your Kafka Connect connectors. It check status of connectors and tasks and restart if they are failed
Kafka Debezium
I built a real-time event pipeline using Apache Kafka and its ecosystem, simulating and displaying Chicago Transit Authority train line statuses using public data.
Change Data Capture (CDC) refers to sourcing database change events from a source database. While there are commercial solutions available in the market, Debezium is available as an open-source option. In this blog post, I am going to show you how to install the Debezium MySQL Connector on Ubuntu machines using Google VM instances.
🍔 Build a production-grade data pipeline for food delivery, enabling real-time insights and features through PostgreSQL, Kafka, and Flink.
A data pipeline demo that streams structured data from Kafka to TimescaleDB using Kafka Connect, ideal for real-time analytics and time-series storage.
End-to-end data pipeline: PostgreSQL CDC (Debezium) → Kafka → Flink SQL → OpenSearch (search) + Redis (features). Local Docker stack, sample data, and verification scripts.
Add a description, image, and links to the kafka-connector topic page so that developers can more easily learn about it.
To associate your repository with the kafka-connector topic, visit your repo's landing page and select "manage topics."