🏥 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
This repository includes data engineering projects using Apache Airflow. I hope to add more projects using different technologies soon!
Kafka Debezium
The goal is to read real-time car telematic data, flatten and aggregate it utilizing Snowflake's advanced capabilities such as Dynamic tables, Snowpipe streaming and so on, in order to generate useful insights that will allow us to understand driver behavior.
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.
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.
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."