前提oracle11g开启logminer
streamsets3.14安装好
准备ojdbc8.jar上传streamsets下lib目录
创建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
JDBC Producer