1 Star 12 Fork 5

左手代码右手诗 / mysql-sync-kafka

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

mysql-sync-kafka

介绍

基于 mysql-binlog-connector-java ,实现同步mysql binlog推送到kafka集群,支持数据库、表过滤

软件架构

springboot项目

安装教程

  1. 打包 mvn package
  2. 启动 java -jar xxx.jar

使用说明

#============== mysql-binlog-connector-java 配置 ===================
binlog:
  kafka-topic: receive_mysql_data2
  mysql:
    server-id: 1 # mysql binglog 设置的server-id
    host: ENC(T6WrTn5zVl4CSinjuxQ0ODWWC2XxUklm) #mysql主机地址 已做加密 工具见 JasyptUtil
    port: 3306
    user: ENC(/hObjoJ3yMR2IE89SYHwwQ==)
    passwd: ENC(HjfpULYrlWVWHvVFCpPFTwF7QDiRklRW)
    # 指定要处理的数据表-必须配置,多个用','分割
    table-filter:
      # 全部填 *,指定某个数据库所有表填写 db_name.*
      includes: "test.*"
      # 不做排除 填写空 "" ,excludes 规则优先级高于 includes
      excludes: "test.t_user2"

# 配置示例:配置db_test监听数据库所有的表,但排除t_user
# includes: "db_test.*"
# excludes: "db_test.t_user"

空文件

简介

基于 mysql-binlog-connector-java ,实现同步mysql binlog推送到kafka集群,支持数据库、表过滤 展开 收起
Java
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
Java
1
https://gitee.com/god007/mysql-sync-kafka.git
git@gitee.com:god007/mysql-sync-kafka.git
god007
mysql-sync-kafka
mysql-sync-kafka
master

搜索帮助