Java教程

MaxWell ops

本文主要是介绍MaxWell ops,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

Download

Download binary distro: https://github.com/zendesk/maxwell/releases/download/v1.33.0/maxwell-1.33.0.tar.gz
Sources and bug tracking is available on github: https://github.com/zendesk/maxwell

homebrew:

brew install maxwell

Configure

$ vi my.cnf
[mysqld]
server_id=1
log-bin=master
binlog_format=row

create database maxwell;
CREATE USER 'maxwell'@'%' IDENTIFIED BY 'xxxx';
GRANT ALL ON maxwell.* TO 'maxwell'@'%';
GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE ON *.* TO 'maxwell'@'%';

FLUSH PRIVILEGES;


Run Maxwell

Command line

创建 kafka topic maxwell

kafka-topics.sh  --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic maxwell
kafka-topics  --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic maxwell

启动MaxWell

后台启动 指定日志输出目录
nohup ./bin/maxwell \
--user='maxwell' \
--password='xxx' \
--host='xxxxxxx \
--producer=kafka \
--kafka_version=1.0.0 \
--kafka.bootstrap.servers=localhost:9092 \
--kafka_topic=maxwell \
--filter='exclude: *.*, include: xxxxdata_test.*' > ./log/maxwell.log &

后台启动
nohup ./bin/maxwell \
--user='maxwell' \
--password='xxxxx' \
--host='xxxx' \
--producer=kafka \
--kafka_version=1.0.0 \
--kafka.bootstrap.servers=localhost:9092 \
--kafka_topic=maxwell \
--filter='exclude: *.*, include: xxxxdata_test.*' &


./bin/maxwell --user='maxwell' \
--password='xxxxx' \
--host='xxxxx \
--producer=stdout
这篇关于MaxWell ops的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!