版本

canal.deployer-1.1.5
canal.admin-1.1.5
rocketmq-all-4.9.3-bin-release
rocketmq-deshboard-master
mysql5.7

官网

链接:canal链接:rocket

操作系统

centos7

mysql5.7安装

链接:centos7上mysql5.7安装

vim /etc/my.cnf

[mysqld]
log-bin=mysql-bin #添加这一行就ok
binlog-format=ROW #选择row模式
server_id=1 #配置mysql replaction需要定义,不能和canal的slaveId重复

配置canal.deployer

wget https://github.com/alibaba/canal/releases/download/canal-1.1.5/canal.deployer-1.1.5.tar.gz# 解压
tar zxcf canal.deployer-1.1.5.tar.gz
-C deployer# 修改cancal.properties
cd conf

vim cancal.properties

# tcp, kafka, rocketMQ, rabbitMQ
canal.serverMode = rocketMQ
rocketmq.producer.group = canal_group
rocketmq.namesrv.addr = 127.0.0.1:9876

vim conf/example/instance.properties

# 源数据库配置
canal.instance.master.address=127.0.0.1:3306
canal.instance.dbUsername=canal
canal.instance.dbPassword=canal# mq config
canal.mq.topic=canal_topic

启动

sh bin/start.sh

配置rocket

# 官网下载rocket二进制包# 启动mqnamesrv
nohup sh bin/mqnamesrv &tail -f ~/logs/rocketmqlogs/namesrv.logThe Name Server boot success...# 启动mqbroker
nohup sh bin/mqbroker -n localhost:9876 &tail -f ~/logs/rocketmqlogs/broker.log The broker[%s, 172.30.30.233:10911] boot success...

操作看看

1.在数据库中新增数据
2.启动rocketmq-deshboard-master打成的jar,看的rocket可视化界面
:Message -> Topic(下拉框选择:canal_topic就可以看的消息了)

canal+mysql+rocket相关推荐

  1. Canal Mysql binlog 同步至 Hbase ES

    文章目录 一.Canal介绍 工作原理 canal 工作原理 二.下载 三.安装使用 Mysql准备 canal 安装 解压缩 canal-deployer 配置修改 启动 查看server日志 查看 ...

  2. canal mysql多实例_canal搭建实例

    canal [k?'næl],译意为水道/管道/沟渠,主要用途是基于 MySQL 数据库增量日志解析,提供增量数据订阅和消费 早期阿里巴巴因为杭州和美国双机房部署,存在跨机房同步的业务需求,实现方式主 ...

  3. canal mysql重置_canal: 首先装完阿里的canal,然后数据库同步,仅供学习参考

    背景 需要将数据库增量内容同步到另外的数据库,两者保持一致.包含增删改,数据库创建.删除,数据库名称修改,内容清空,表结构修改,索引创建.修改.删除. 方案 采用阿里巴巴Canal,用于监听mysql ...

  4. kafka mysql安装与配置_Mac环境canal+mysql+kafka的安装及使用

    为了实现 实时同步数据,在mac环境搭建了canal,mysql,kafka的一套流程 使用canal加mysql加kafka的方式传递数据 mysql 数据源头 canal模仿slave冲mysql ...

  5. mysql数据实时同步:Canal安装部署、kafka安装、zk安装、mysql安装、Canal Server+Canal Client HA,Canal+mysql+Kafka,相关验证(学习笔记)

    目录 Canal安装部署 1.1. 服务器准备 1.2. 设置主机名并配置hosts 1.3. 免密设置 1.4. 设置ntp时间 1.5. 关闭防火墙 1.6. 关闭selinux 1.7. 安装J ...

  6. canal mysql 数据同步

    首先canal是什么呢? canal是阿里巴巴旗下的一款开源项目,纯Java开发.基于数据库增量日志解析,提供增量数据订阅&消费,目前主要支持了MySQL:简单来说,canal 会将自己伪装成 ...

  7. canal mysql从库_canal中间件|数据增量同步解决方案

    上一文中提到延时双删等策略实现数据一致性的时候,可能存在删除缓存失败的情况,就会出现缓存和数据库不一致的问题.为了应对删除缓存失败而导致数据不一致的问题,可以通过回溯数据库日志文件,提供一个保障的重试 ...

  8. Canal Mysql binlog 同步至 ElasticSearch 详细介绍

    文章目录 数据同步ElasticSearch 单表基本配置 适配器映射文件详细介绍(单表.多表映射介绍) 单表映射索引示例sql 单表映射索引示例sql带函数或运算操作 多表映射(一对一, 多对一)索 ...

  9. Canal Mysql同步至ES/Hbase只有新增时生效,修改删除不生效

    问题描述 新增Mysql数据时,ES.Hbase数据会同步成功:当删除Mysql数据,或者修改Mysql数据时同步ES.Hbase数据无变化(PS:修改和删除加上LIMIT xxx 就可以成功.) 问 ...

最新文章

  1. c语言随机三位数,【分享代码】弥补c语言随机数不足
  2. android网页无法定位吗,在android中,js 无法定位 html页面的某元素
  3. Filter若不写chain.doFilter(request,response)原Servlet路径代码不会被执行
  4. 远望资本田鸿飞:中国产业互联网的关键是AI赋能
  5. PHPMailer——发送邮件函数封装
  6. 计算机检索技巧知识,初学者常用电脑技巧知识
  7. Apache Maven ToolChains的使用
  8. python3入门基础语法总结_Python基础语法总结
  9. 跨语言RPC框架Thrift详解
  10. oracle ldap 配置,ldap 安装
  11. 设计模式学习笔记(5) - 策略模式
  12. 360怎么看电脑配置_电脑配置清单速查表-AMD
  13. mac上超好用的文字转语音工具【迅捷文字转语音】
  14. Hadoop 2.6.0 FileSplit和InputSplit和FileInputFormat
  15. 怎么把图片的边缘弄圆_ps里面照片怎么把边缘变成椭圆形
  16. linux每个进程有4g,32位Linux单进程有4G内存限制
  17. indesign选中不了图片删除_文件夹删除不了怎么办?文件夹删除不了的解决方法...
  18. 安全加密邮箱哪个好?
  19. 论文笔记:Meta-attention for ViT-backed Continual Learning CVPR 2022
  20. Spring Web Flow 2中的流管理持久性

热门文章

  1. clickhouse批量写入_交互式分析领域,为何 ClickHouse 能够杀出重围?
  2. “利他主义者”乔治·普莱斯的一生(全文翻译自Independent)
  3. R语言ggplot2可视化散点图实战:绘制基础散点图、为所有散点添加标签、只为大于阈值的散点添加标签
  4. 什么是推理统计(inferential statistics)?
  5. 流数据分析平台Storm简介
  6. R语言bioconductor包—maftools的使用
  7. java里面怎么导入sql文件_java将SQL文件导入到数据库
  8. 使用Oracle创建图书馆数据库
  9. Producing Simple Graphs with R
  10. Error Correction and DeNovo Genome Assembly for the MinION Sequencing Reads mixing Illumina Short Re