1:首先下载maxwell https://github.com/zendesk/maxwell/releases/download/v1.24.1/maxwell-1.24.1.tar.gz

(这玩意下的很慢,建议去论坛找)

2:下载安装mysql (安装mysql比较简单自行查找)

3:给你的mysql配置文件里加上 binlog配置

[mysqld]
server_id=1
log-bin=master
binlog_format=row

还有一种配置方式,在mysql启动后执行以下命令:

mysql> set global binlog_format=ROW;
mysql> set global binlog_row_image=FULL;

4:maxwell读取binlog需要一个账号,那么我们就在mysql里面为maxwell配置一个账号

mysql> CREATE USER 'maxwell'@'%' IDENTIFIED BY 'XXXXXX';
mysql> GRANT ALL ON maxwell.* TO 'maxwell'@'%';
mysql> GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE ON *.* TO 'maxwell'@'%';

5:运行你的maxwell

进入到你下载解压的maxwell文件夹里执行下面的命令

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

注意:如果你是mysql8.0,会报出以下错误:com.github.shyiko.mysql.binlog.network.AuthenticationException: Client does not support authentication protocol requested by server; consider upgrading MySQL client

出现上述问题的原因是:mysql8 之前的版本中加密规则是mysql_native_password,而在mysql8之后,加密规则是caching_sha2_password 把mysql用户登录密码加密规则还原成mysql_native_password

解决方案:在mysql中执行以下命令

alter user 'maxwell'@'%' identified with mysql_native_password by 'XXXXXX';  修改认证规则

flush privileges;  刷新权限

之后重新运行一遍

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

--user mysql数据库用户名
--password  mysql数据库密码
--host mysql 数据库服务器
--producer  指定数据输出到哪里
# 以上为必须要的,以下的kafka相关的是以kafka方式启动时需要的参数,kafka相关分区参数在此未指定
--kafka.bootstrap.servers 指定kafka地址
--kafka_topic  指定kakfa的topic是哪一个
# 以下可选
--daemon  守护进程 后台运行
--filter  过滤条件,可以过滤数据库,表,列等等

6:出现binlog cennected 你会发现maxwell启动成功

7:我在mysql创建了一个表

 再看maxwell的控制台

教程到此完结!

maxwell deamon 监听mysql binlog 二进制文件实现数据同步到相关推荐

  1. 使用canal 监听mysql binlog获取增量数据

    配置mysql sudo vi /etc/my.cnf [mysqld] log-bin=/var/lib/mysql/mysql-bin #开启日志监控 binlog-format=ROW #监控模 ...

  2. springboot整合canal,监听MySQL binlog日志,实现增量同步

    有两个数据库,并不是主从关系,但是需要同步某张表,可以通过binlog日志,进行同步,前提是这两个数据库的要同步的表,表名和字段名需要一致. 当前项目连接的数据库(需要同步的数据库):base_pro ...

  3. elasticsearch 数据类型_基于 MySQL Binlog 的 Elasticsearch 数据同步实践

    来源;马蜂窝 一.背景 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品.订单等数据的多维度检索. 使用 Elasticsearch 存 ...

  4. 基于 MySQL Binlog 的 Elasticsearch 数据同步实践

    一.为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品.订单等数据的多维度检索. 使用 Elasticsearch 存储业务数 ...

  5. 基于 MySQL Binlog 的 Elasticsearch 数据同步实践 原

    一.背景 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品.订单等数据的多维度检索. 使用 Elasticsearch 存储业务数据可以 ...

  6. canal mysql多节点_数据同步的终极解决方案,阿里巴巴开源的Canal框架当之无愧!!...

    写在前面 在当今互联网行业,尤其是现在分布式.微服务开发环境下,为了提高搜索效率,以及搜索的精准度,会大量使用Redis.Memcached等NoSQL数据库,也会使用大量的Solr.Elastics ...

  7. Java监听mysql的binlog详解(mysql-binlog-connector)

    Java监听mysql的binlog详解(mysql-binlog-connector) 1. 需求概述 2. 技术选型 3. 方案设计 3.环境准备 3.1 查看是否开启binlog 3.2 mys ...

  8. Canal监听mysql的binlog日志实现数据同步

    Canal监听mysql的binlog日志实现数据同步 1. canal概述 1.1 canal简介 1.2 技术选型 1.3 原理分析 1.3.1 MySQL主备复制原理 1.3.2 canal原理 ...

  9. spring boot+kafka+canal实现监听MySQL数据库

    spring boot+kafka+canal实现监听MySQL数据库 一.zookeeper安装 kafka依赖于zookeeper,安装kafka前先安装zookeeper 下载地址:Apache ...

最新文章

  1. indows上的android开发环境软件架构5
  2. 关于“编程的本质”的探讨
  3. mysql 图形化工具
  4. matlab如何创建callback函数_如何学好MATLAB GUI
  5. C++STL总结笔记(二)——仿函数(函数对象)
  6. mysql数据库中的int类型_MySQL中int(M)和tinyint(M)数值类型中M值的意义
  7. 解决 : Could not commit JPA transaction RollbackException: Transaction marked as rollbackOnly
  8. python模式匹配算法_详解Python 最短匹配模式
  9. sklearn 使用joblib保存模型,并解决cannot import name joblib from sklearn.externals报错
  10. 前端-选项卡(菜单栏)
  11. java 异步i o_在Java中播放框架异步处理和阻塞I / O
  12. NSString 和 NSMutableString
  13. Bailian2715 谁拿了最多奖学金【分段计算处理】(Vijos P1001)
  14. 聊聊机器学习中的损失函数(hinge/soft/square/0-1)
  15. Communication System dp 动态规划 || 贪心
  16. B2065 鸡尾酒疗法
  17. 慢下来,等一等自己的灵魂
  18. IDEA导入Eclipse项目--ecli
  19. 北京PMP考试考点在哪里?
  20. AirDisk存宝Q2 网盘转接器 移动硬盘伴侣NAS私有云

热门文章

  1. 服务器pe装系统找不到硬盘,用U盘PE装系统找不到硬盘如何解决妙招
  2. 用这8个办公软件,效率高一倍
  3. 小程序中将lees转成wxss
  4. Nginx的http_access_module模块
  5. SPSS 顾客购买习惯调查问卷案例分析
  6. 视频提取音频怎么弄?快把这些方法收好
  7. Thor UI - 轻量简洁的免费开源移动端 UI 组件库,支持原生小程序和 uni-app
  8. java打印菱形图案_java打印出菱形图案实例详解
  9. java语言就业方向_java就业有哪些方向
  10. 单系统 台电x80pro_台电X80 Pro (E6E9)-双系统安装文件平板固件