🏥 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

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.

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.

A data pipeline demo that streams structured data from Kafka to TimescaleDB using Kafka Connect, ideal for real-time analytics and time-series storage.