前提oracle11g开启logminer

streamsets3.14安装好

准备ojdbc8.jar上传streamsets下lib目录

streamsets 同步oracle11g数据

 

 创建test表和t_test表,两个表结构一样,向test表插入数据streamsets同步至t_test表中

 create table STREAMSETS.TEST
(
  id              VARCHAR2(36) not null,
  name            VARCHAR2(50) not null
);

insert into STREAMSETS.TEST(id,name) values('1','zhangsan');
commit;

oracle cdc client

streamsets 同步oracle11g数据

 

 streamsets 同步oracle11g数据

 

 streamsets 同步oracle11g数据

 

 streamsets 同步oracle11g数据

 

 JDBC Producer

streamsets 同步oracle11g数据

 

相关文章: