1、创建pipeline
创建新的pipeline binlog2kudu。
2、MySQL Binary Log
这块和之前配置一样,重新指定一个server id
3、Field Renamer
4、Kudu
注意选择与自己kudu集群一致的stage library
kudu的master需要手动填写,端口默认7051,表名依然动态获取,如果是impala创建的kudu表记得加上前缀impala::default.
5、运行
创建新的pipeline binlog2kudu。
这块和之前配置一样,重新指定一个server id
注意选择与自己kudu集群一致的stage library
kudu的master需要手动填写,端口默认7051,表名依然动态获取,如果是impala创建的kudu表记得加上前缀impala::default.
相关文章: