Debezium Kullanımı İçin Hazırlık

1. User ve Role Yaratılır

Şöyle yaparız

CREATE USER 'debezium'@'localhost' IDENTIFIED BY 'passme';
CREATE USER 'debezium'@'%' IDENTIFIED BY 'passme';

GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* 
TO 'debezium'@'localhost';
GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* 
TO 'debezium'@'%';

2. /etc/mysql/my.cnf

Şöyle yaparız

[mysqld]
log-bin=mysql-bin
binlog-format=ROW
server-id=1

3. Kafka'ya Kurulum

Şöyle yaparız

# download the connector
curl https://repo1.maven.org/maven2/io/debezium/debezium-connector-mysql/1.5.0.Final/debezium-connector-mysql-1.5.0.Final-plugin.tar.gz | tar xvz

# Copy the connector files to the Kafka plugin directory.
cp debezium-connector-mysql/debezium-connector-mysql-1.5.0.Final.jar /usr/local/s