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

 

相关文章:

  • 2021-09-05
  • 2021-11-14
  • 2022-12-23
  • 2021-08-20
  • 2022-01-04
  • 2021-09-10
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2021-12-15
  • 2021-09-01
  • 2022-02-16
  • 2022-12-23
  • 2022-12-23
  • 2021-04-28
相关资源
相似解决方案