maxwell mysql_mysql的maxwell的使用

隻有mysql 可以使用此功能。

注意：此功能隻有mysql可以使用。 阿裡的canal也可以實作此功能，但是我用起來問題有點多。

postgresql也有類似的功能，但是不使用的此軟體。可以自己查找pg_recvlogical test_decoding wal2json pgcat Logical Decoding 和最新的PgOutput。postgresql基本都是用插件實作。

一 mysql的部分

1開啟邏輯複制功能

[mysqld]

server_id=1

log-bin=master

binlog_format=row

2設定用來複制的賬号,使用者名maxwell 密碼xxxxxx

mysql> CREATE USER 'maxwell'@'%' IDENTIFIED BY 'XXXXXX';

mysql> GRANT ALL ON maxwell.* TO 'maxwell'@'%';

mysql> GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE ON *.* TO 'maxwell'@'%';

maxwell的使用

1 指令行方式

輸出到控制台

bin/maxwell --user='maxwell' --password='XXXXXX' --host='127.0.0.1' --producer=stdout

輸出到rabbitmq

bin/maxwell --user='maxwell' --password='XXXXXX' --host='127.0.0.1' \

--producer=rabbitmq --rabbitmq_host='rabbitmq.hostname'

輸出到redis

bin/maxwell --user='maxwell' --password='XXXXXX' --host='127.0.0.1' \

--producer=redis --redis_host=redis.hostname

2 docker

輸出到控制台

docker run -it --rm zendesk/maxwell bin/maxwell --user=$MYSQL_USERNAME \

--password=$MYSQL_PASSWORD --host=$MYSQL_HOST --producer=stdout

輸出到kafka

docker run -it --rm zendesk/maxwell bin/maxwell --user=$MYSQL_USERNAME \

--password=$MYSQL_PASSWORD --host=$MYSQL_HOST --producer=kafka \

--kafka.bootstrap.servers=$KAFKA_HOST:$KAFKA_PORT --kafka_topic=maxwell

标簽：bin,--,maxwell,mysql,host,MYSQL,使用

來源： https://www.cnblogs.com/wang2650/p/14366063.html