NO.1 ORCLA注意事项
数据库必须处于archivelog模式，并且必须启用补充日志记录。

在数据库服务器上：

注：alter database add supplemental log data (all) columns 是指启用补充日志记录。

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

1.用有dba权限的用户登录：sys用户

2.创建一个新用户：create user abc identified by 123456;

3.授予DBA权限： grant connect,resource,dba to abc;

ok,创建好了，就可以用abc这个用户登录了，abc用户拥有dba权限。

select * from dba_users; 查看数据库里面所有用户，前提是你是有dba权限的帐号，如sys,system
select * from all_users; 查看你能管理的所有用户！
select * from user_users; 查看当前用户信息 ！

NO.2简单的创建一个Oracle表

SQL> create table test_kafka(id VARCHAR(50) NOT NULL,username varchar2(100));

NO.3 添加相关组件
1）从https://github.com/erdemcer/kafka-connect-oracle下载整个项目，把整个项目mvn clean package成kafa-connect-oracle-1.0.jar。
2）下载一个oracle的jdbc驱动jar—ojdbc7.jar
3）将kafa-connect-oracle-1.0.jar and ojdbc7.jar放在kafka的安装包下的lib目录下，
4）将github项目里面的config/OracleSourceConnector.properties文件拷贝到kafak/config

No.4 修改配置文件

[root@localhost config]# vim connect-standalone.properties

[root@localhost config]# vim OracleSourceConnector.properties

NO.5 启动kafka

[root@localhost bin]# ./kafka-server-start.sh …/config/server.properties

1.创建Topic

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-Oracle

2.启动connector

[root@localhost bin]# ./connect-standalone.sh …/config/connect-standalone.properties …/config/OracleSourceConnector.properties

-----启动成功会有以下信息：

3.启动consumer

[root@localhost bin]# ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic huang-Oracle

启动成功会等待topic数据，然后消费到控制台

NO.6在数据库中插入一条数据

SQL> INSERT INTO test_kafka values(‘1’,‘huang’);

一定注意commit提交，否则kafka不会收到数据

可以看到在消费的控制台上出现：

插入的值以key:value的形式打印到控制台上。

同样删除和修改也会将信息打印到控制台上，会在key为data以及before上体现不同。

这样也就实现了oracle中的数据在Insert时与kafka同步。