# lzmh_ad_canal

**Repository Path**: heiping/lzmh_ad_canal

## Basic Information

- **Project Name**: lzmh_ad_canal
- **Description**: 公司封装的 canal 客户端， 通过监听mysql 数据表(Insert  update  delete)操作，然后获取变更签后的数据变化，将变更后的数据 发送到kafka 队列。 发送json格式的数据类型，包括 变更类型， 变更后的值， 变更的数据表名， 发送kafka 的topic命名格式为：ad-表名-cache
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2019-07-22
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# lzmh_ad_canal

#### 介绍
公司封装的 canal 客户端， 通过监听mysql 数据表(Insert  update  delete)操作，然后获取变更签后的数据变化，
将变更后的数据 发送到kafka 队列。 发送json格式的数据类型，包括 变更类型， 变更后的值，
 变更的数据表名， 发送kafka 的topic命名格式为：ad-表名-cache

#### 软件架构
1.canal
2.mysql
3.kafka

#### 安装教程

1. canal介绍： https://www.cnblogs.com/maxigang/p/9134523.html
              https://www.cnblogs.com/yulu080808/p/8819260.html

2.canal安装教程： https://blog.csdn.net/qq_32254003/article/details/76837638
3.简单说明： canal 实际是根据mysql 主从原理实现， mysql slave 通过给master 发送dump文件， master给slave推送
            bing log日志， slave 有一个I/O Thread 去读取bing log日志，然后有一个SQL 线程去处理bing log日志，
            同时进行相关操作， 实现主从。 canal 将自己伪装成一个slave .

#### 使用说明

1. 此工程实现了，监听配置的数据库表 新增 修改  删除  变化，并将变化的数据封装为json对象后发送到kafka 队列。
2. 实际使用的时候，根据个人需求修改配置即可。

#### 参与贡献

1. Fork 本仓库
2. 新建 Feat_xxx 分支
3. 提交代码
4. 新建 Pull Request


#### 码云特技

1. 使用 Readme\_XXX.md 来支持不同的语言，例如 Readme\_en.md, Readme\_zh.md
2. 码云官方博客 [blog.gitee.com](https://blog.gitee.com)
3. 你可以 [https://gitee.com/explore](https://gitee.com/explore) 这个地址来了解码云上的优秀开源项目
4. [GVP](https://gitee.com/gvp) 全称是码云最有价值开源项目，是码云综合评定出的优秀开源项目
5. 码云官方提供的使用手册 [https://gitee.com/help](https://gitee.com/help)
6. 码云封面人物是一档用来展示码云会员风采的栏目 [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)