debezium-mysql

An example using debezium and mysql with docker-compose

The docker compose starts the Zookeeper, Kafka, Mysql and Debezium Connect.

After the containers getting healthy you can create a new connector, listening changes into mysql inventory database.

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{ "name": "inventory-connector", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "tasks.max": "1", "database.hostname": "mysql", "database.port": "3306", "database.user": "debezium", "database.password": "dbz", "database.server.id": "184054", "database.server.name": "dbserver1", "database.include.list": "inventory", "database.history.kafka.bootstrap.servers": "kafka:9092", "database.history.kafka.topic": "dbhistory.inventory" } }'

Therefore you can get the connectors calling

curl -H "Accept:application/json" localhost:8083/connectors/

You can also get the connectors by their names

curl -i -X GET -H "Accept:application/json" localhost:8083/connectors/inventory-connector

Instaling python library

pip install -r requirements.txt

Running the python example

python kafka-example.py

An example using debezium and mysql with docker-compose

Related tags

Overview

debezium-mysql

The docker compose starts the Zookeeper, Kafka, Mysql and Debezium Connect.

After the containers getting healthy you can create a new connector, listening changes into mysql inventory database.

Therefore you can get the connectors calling

You can also get the connectors by their names

Instaling python library

Running the python example

The aplication listen a topic called "dbserver1.inventory.customers"

You can see the columns, the values before and after the changes.

Owner

Horácio Dias Baptista Neto

Cup Noodle Vending Maching Ordering Queue

Python-geoarrow - Storing geometry data in Apache Arrow format

Fly DCS without a joystick

For Tok-k passages that have passed through the Bi-Encoder Retrival, ReRank is performed using CrossEncoder.

Project 2 for Microsoft Azure on WUT

python scripts and other files to generate induction encoder PCBs in Kicad

Pytorch implementation of "Peer Loss Functions: Learning from Noisy Labels without Knowing Noise Rates"

Python Create Your Own Tool Series

Bots in moderation and a game (for now)

A minimalist personal blogging system that natively supports Markdown, LaTeX, and code highlighting.

A collection of Python library code for building Python applications.

Ramadhan countdown - Simple daily reminder about upcoming Ramadhan

A TODO-list tool written in Python

Proyecto desarrollado para el programa #FutureDevelopers, tabla periódica interactiva.

Awesome & interesting talks about programming

A napari plugin to inspect data within a cisTEM project

Automated rop chain generation

Pacman - A suite of tools for manipulating debian packages

Cross-platform config and manager for click console utilities.

Why write code when you can import it directly from GitHub Copilot?