首页 / MYSQL / 在kafka connect 同步 mysql 主从数据库

在kafka connect 同步 mysql 主从数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了在kafka connect 同步 mysql 主从数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1134字，纯文字阅读大概需要2分钟。

内容图文

下载以下文件,解压，放置到kafka的libs目录

kafka-connect-jdbc-4.1.1

从这里选择适合的mysql connector

https://dev.mysql.com/downloads/connector/j/

将里面的jar文件提取出来，也放到kafka的libs目录

在config目录下创建 connect-mysql-source.properties

内容为

name=mysql-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://192.168.101.3:3306/tablename?user=xxx&password=xxx
mode=incrementing
incrementing.column.name=HeatMapId
topic.prefix=mysql-jdbc-

注意更改jdbc的表名，用户名 密码

./kafka-server-start.sh ../config/server.properties &
bin/connect-standalone.sh config/connect-standalone.properties config/connect-mysql-source.properties &

如果报

The server time zone value ” is  unrecognized or represents more than one time 。。。

以命令行进入mysql

mysql> show variables like '%time_zone%';
+------------------+--------+
| Variable_name    | Value  |
+------------------+--------+
| system_time_zone |        |
| time_zone        | SYSTEM |
+------------------+--------+
2 rows in set

如果输出结果是system

设置time_zone即可

mysql> set global time_zone='+8:00';
Query OK, 0 rows affected

内容总结

以上是互联网集市为您收集整理的在kafka connect 同步 mysql 主从数据库全部内容，希望文章能够帮你解决在kafka connect 同步 mysql 主从数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/911351.html

来源：【匿名】