kafka-connect-oracle - 墨天轮文档

kafka-connect-oracle

bicewow

2097

8页

9次

2020-09-23

5墨值下载

文章介绍
环境准备
软件准备
下载地址
实施过程
Oracle主机（A）配置
Kafka主机（B）配置
主机hosts文件添加解析
安装JDK
配置apache-maven工具
配置Kafka 2.13-2.6.0 
配置kafka-connect-oracle-maste
启动kafka-connect-oracle
启动kafka消费者
启动数据库JOB
kafka消费者界面
文章介绍  
  本文章介绍如何使用kafka-connect-oracle开源工具，将Oracle dml产生的数据实时同步至kafka，供
kafka消费。
环境准备  
软件准备  
CentOS Linux 7.6.1810 （2台，A主机，B主机）
Oracle 11.2.0.4（A主机安装）
Kafka 2.13-2.6.0 （B主机安装）
kafka-connect-oracle-master （B主机安装，开源程序，用于同步Oracle数据到kafka）
apache-maven 3.6.3 （B主机安装，kafka-connect-oracle-master 的打包工具）
jdk-8u261-linux-x64.rpm（B主机安装）
下载地址  
Cenos 和Oracle 和 JDK 自行到官网下载
Kafka http://kafka.apache.org/downloads
kafka-connect-oracle-master https://github.com/erdemcer/kafka-connect-oracle

apache-maven 3.6.3 http://maven.apache.org/download.cgi

实施过程

Oracle主机（A）配置

Oracle实例配置项：

开启归档日志

开启附加日志

创建kafka-connect-oracle-master连接用户

创建测试数据生成用户及测试表

--开启归档日志

sqlplus / as sysdba  

SQL>shutdown immediate

SQL>startup mount

SQL>alter database archivelog;

SQL>alter database open;

--开启附加日志

SQL>alter database add supplemental log data (all) columns;

--创建kafka-connect-oracle-master连接用户

create role logmnr_role;

grant create session to logmnr_role;

grant execute_catalog_role,select any transaction ,select any dictionary to

logmnr_role;

create user kminer identified by kminerpass;

grant logmnr_role to kminer;

alter user kminer quota unlimited on users;

--创建测试数据生成用户及测试表

create tablespace test_date datafile

'/u01/app/oracle/oradata/zzsrc/test_date01.dbf' size 100M autoextend on next

10M;

create user whtest identified by whtest default tablespace test_date;

grant connect,resource to whtest;

grant execute on dbms_scheduler to whtest;

grant execute on dbms_random to whtest;

grant  create job to whtest;

create table t1 (

id int ,

name char(10),

createtime date default sysdate

);

of 8

5墨值下载

oracle kafka

关注

评论