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
1 Dec 22, 2021
54 Jan 02, 2023
12 May 08, 2022
105 Oct 17, 2022
9.5k Jan 09, 2023
35 Dec 24, 2022
30 Nov 28, 2022
3 Jul 09, 2022
12 Nov 09, 2022
231 Dec 26, 2022
3 Feb 15, 2022
4.1k Jan 02, 2023
1 Jan 07, 2022
1 Feb 08, 2022
2 Jul 30, 2022
3 Nov 02, 2022
12 Oct 25, 2022
82 Dec 26, 2022
11 Jan 05, 2023
21 Nov 21, 2022