使用kafka-connect-oracle采集oracle数据

1.下载软件包

将kafka-connect-oracle的jar包放到kafka客户端的libs目录下，并将连接oralce的驱动包ojdbc的jar包（根据oracle的版本选择jar包，此处使用的是ojdbc6.jar）放到kakfa客户端libs目录下。

2.登录oracle数据库，对用户授权

a.数据库必须处于archivelog模式：

**c.为了成功执行连接器，必须使用特权Oracle用户启动连接器。**如果给定的用户具有DBA角色，则可以跳过此步骤。否则，需要执行以下脚本来创建特权用户：

db.name 可以登录oracle使用如下命令进行查看：

需要注意表的名称需要大写。例如：

4.运行测试

首先运行zookeeper服务，进入kafka客户端，执行如下命令：

启动成功后如图所示：

最后在kafka客户端启动kafka-connect-oracle服务：

运行成功如图所示：

消费student主题：

登录oracle操作数据（增删改）：

操作结果如图所示：

可以看到成功消费到数据，测试成功。

文章知识点与官方知识档案匹配，可进一步学习相关知识云原生入门技能树首页概览8743 人正在系统学习中