代码拉取完成,页面将自动刷新
同步操作将从 左手代码右手诗/mysql-sync-kafka 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
基于 mysql-binlog-connector-java ,实现同步mysql binlog推送到kafka集群,支持数据库、表过滤
springboot项目
#============== 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"
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。