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

Inspect the resources of your android projects and understand which ones are not being used and could potentially be removed.

Rufus port to linux, writed on Python3

ChronoRace is a tool to accurately perform timed race conditions to circumvent application business logic.

Display your data in an attractive way in your notebook!

Sample microservices application demo

It converts ING BANK account historic into a csv file you can import in HomeBank application.

PwnDatas-DB-Project(PDDP)

Prometheus exporter for Spigot accounts

Anki Addon idea by gbrl.sc to see previous ratings of a card in the reviewer

MeerKAT radio telescope simulation package. Built to simulate multibeam antenna data.

Construção de um jogo Dominó na linguagem python com base em algoritmos personalizados.

Python client SDK designed to simplify integrations by automating key generation and certificate enrollment using Venafi machine identity services.

Aggressor script that gets the latest commands from CobaltStrikes web site and creates an aggressor script based on tool options.

This is the Code Institute student template for Gitpod.

An app to help people apply for admissions on schools/hostels

libvcs - abstraction layer for vcs, powers vcspull.

Convert Roman numerals to modern numerals and vice-versa

A Company Management System For Python

Awesome Cheatsheet