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

Gerenciador de processos e registros pessoais do Departamento de Fiscalização de Produtos Controlados.

program to store and update pokemons using SQL and Flask

The program converts Swiss notes into American notes

A basic animation modding workflow for FFXIV

Quantity Takeoff with Python. Collecting groups of elements by filters

A play store search module

Draw random mazes in python

Basic-Killfeed - A simple DayZ Console Killfeed

Commodore 64 OS running on Atari 8-bit hardware

ARK sõidueksami Matrixi bot

An Airflow operator to call the main function from the dbt-core Python package

Mata kuliah Bahasa Pemrograman

Airbrake Python

A brainfuck-based game oriented language written in python.

Account Manager / Nuker with GUI.

A python tool used for hacking WhatsApp by diverting otp

All solutions for the 2021 Advent of Code event.

Manipulation OpenAI Gym environments to simulate robots at the STARS lab

Grimoire is a Python library for creating interactive fiction as hyperlinked html.

A Python program for calculating the 95%CI for GNSS-derived site velocities