1、创建pipeline

创建新的pipeline binlog2kudu。

2、MySQL Binary Log

这块和之前配置一样,重新指定一个server id

Streamsets(七)SS读取binlog数据实时同步到kudu

 

Streamsets(七)SS读取binlog数据实时同步到kudu

 

 

Streamsets(七)SS读取binlog数据实时同步到kudu

 

Streamsets(七)SS读取binlog数据实时同步到kudu

 

3、Field Renamer

Streamsets(七)SS读取binlog数据实时同步到kudu

 

Streamsets(七)SS读取binlog数据实时同步到kudu

4、Kudu

注意选择与自己kudu集群一致的stage library

Streamsets(七)SS读取binlog数据实时同步到kudu

kudu的master需要手动填写,端口默认7051,表名依然动态获取,如果是impala创建的kudu表记得加上前缀impala::default.

Streamsets(七)SS读取binlog数据实时同步到kudu

 

Streamsets(七)SS读取binlog数据实时同步到kudu

 

5、运行

Streamsets(七)SS读取binlog数据实时同步到kudu

 

相关文章: