StreamSets解析MySQL Binlog写入Kafka

Posted 光于前裕于后

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了StreamSets解析MySQL Binlog写入Kafka相关的知识,希望对你有一定的参考价值。

前面与写入HBase一样,StreamSets解析MySQL Binlog写入HBase
1.创建Data Collector新管道

2.进入后会显示缺失原始节点,自动弹出框让我们选择,此时我们选择mysql Binlog

3.配置要解析的MySQL Binlog信息,注意sever id 不能重复!

4.配置要解析的表,可以写多个,逗号隔开

5.点击左下角红色叹号,配置错误日志输出,这里选择写入文件

6.选择Jython

以上是关于StreamSets解析MySQL Binlog写入Kafka的主要内容,如果未能解决你的问题,请参考以下文章

StreamSets解析MySQL Binlog写入Kafka

StreamSets解析MySQL Binlog写入HBase

StreamSets解析MySQL Binlog写入HBase

StreamSets解析MySQL Binlog写入HBase

请问怎样修改mysql的binlog位置

如何读取mysql binlog 解析