栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

canal将mysql实时日志信息发送到kafka

canal将mysql实时日志信息发送到kafka

canal将mysql实时日志信息发送到kafka的topic注意事项:
1.注意看example.log和canal.log日志文件,有启动信息和日志。
2.版本1.1.6调整为1.1.4
3.如果mysql服务器在windows本地,这里不用变动:canal.instance.master.address=127.0.0.1:3306
4.如果kafka需要Kerberos认证,注意目录不能加引号

canal.mq.kafka.kerberos.enable = true
canal.mq.kafka.kerberos.krb5FilePath = D:/data/krb5.ini
canal.mq.kafka.kerberos.jaasFilePath = D:/data/kafka_jaas.ini

发送到topic后就可以使用Java通过flink将数据实时入库到目标端。实现实时的数据同步。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/751254.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号