Matheus Jericó
Menu
All projects

Project / 03

Change Data Capture on Kubernetes

Stream MySQL changes through Kafka and Debezium on Kubernetes. Includes connector configuration and a FastAPI consumer you can run.

Year
2024
Artifact type
Public source

What it demonstrates

The repository connects MySQL change capture to Kafka Connect and Debezium on Kubernetes, then exposes a small FastAPI consumer for inspecting the resulting messages.

Repository map

  • kafka/kafka-cluster.yaml, kafka/mysql-kafka-connect.yaml, and kafka/mysql-kafka-connector.yaml define the Kafka and connector resources.
  • mysql/mysql-values.yaml configures the MySQL source.
  • kafka/image/Dockerfile builds the Kafka Connect image and kafka/image/plugins/debezium-connector-mysql/ contains the connector files.
  • api/main.py, api/Dockerfile, and api/fastapi-deployment.yaml define the FastAPI consumer and deployment.

Inspect the source

Review the repository and the supporting article.