1.文档编写目的
本篇文章主要介绍如何使用StreamSets实现MySQL中变化数据实时写入HBase。
StreamSets实现的流程如下:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-eZ3iOyZw-1645423030593)(https://ask.qcloudimg.com/http-save/yehe-1522219/q9904vro87.jpeg?imageView2/2/w/1620)]](https://img-blog.csdnimg.cn/2c2b7bbefd5d43008b07705444f7e92a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6I-c6bif6JyA6buN,size_20,color_FFFFFF,t_70,g_se,x_16)
- 内容概述
1.环境准备
2.创建StreamSets的Pipeline流程
3.Pipeline流程测试
4.总结
- 测试环境
1.StreamSets版本为3.3.0
2.CM和CDH版本为5.12.1
3.MariaDB版本为5.5.56
2.环境准备
1.开启MariaDB的Binlog日志
修改/etc/my.conf文件,在配置文件[mysqld]下增加如下配置
server-id=1
log-bin=mysql-bin
binlog_format=ROW
&#x
版权声明:本文为u013522009原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。