【发布时间】：2020-07-03 16:16:51
【问题描述】：
当我创建 kafka jdbc 源连接器（使用 confluent-5.4.0 的 oracle 的 debezium 连接器）时，出现错误“找不到适用于 jdbc:oracle:oci 的驱动程序...”。
[2020-03-23 11:49:44,521] ERROR WorkerSourceTask{id=debezium-souce-inventory-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped.
at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:170)
at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
at io.debezium.connector.oracle.OracleConnectorTask.poll(OracleConnectorTask.java:110)
at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.RuntimeException: java.sql.SQLException: No suitable driver found for jdbc:oracle:oci:@test:1521/testdb
at io.debezium.relational.RelationalSnapshotChangeEventSource.execute(RelationalSnapshotChangeEventSource.java:179)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:83)
... 5 more
Caused by: java.sql.SQLException: No suitable driver found for jdbc:oracle:oci:@test:1521/testdb
at java.sql.DriverManager.getConnection(DriverManager.java:689)
at java.sql.DriverManager.getConnection(DriverManager.java:247)
at io.debezium.connector.oracle.OracleConnectionFactory.connect(OracleConnectionFactory.java:25)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:756)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:751)
at io.debezium.relational.RelationalSnapshotChangeEventSource.execute(RelationalSnapshotChangeEventSource.java:119)
... 6 more
[2020-03-23 11:49:44,521] ERROR WorkerSourceTask{id=debezium-souce-inventory-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180)
我的 oracle 版本是 Enterprise Edition Release 11.2.0.4.0 - 64bit Production，我尝试了不同的驱动程序 jar，但得到了相同的异常。
我的jdk版本是：
[root@vtsz-big-dwh02 /]# echo $JAVA_HOME
/usr/java/jdk1.8.0_191
我已将 debezium-connector-oracle 添加到文件夹 confluent-5.4.0/share/java。
正如 Debezium 文档所说，我安装了即时客户端并将文件 _ojbc8.jar 和 xtreams.jar 从即时客户端复制到 Kafka 的库中
目录
（confluent-5.4.0/share/java/kafka，confluent-5.4.0/share/java/kafka-connect-jdbc ,/opt/confluent-5.4.0/lib,/usr/share/java`）。
[root@vtsz-big-dwh02 java]# echo $LD_LIBRARY_PATH
/home/app/instantclient_11_2/:
我的源连接器配置是：
{
"name": "debezium-souce-idea-inventory",
"config": {
"connector.class": "io.debezium.connector.oracle.OracleConnector",
"tasks.max": "1",
"database.server.name":"testdb",
"database.out.server.name":"testdb",
"database.hostname": "10.0.10.169",
"database.port": "1521",
"database.user": "mytest",
"database.password": "mytest",
"database.dbname" : "testdb",
"table.whitelist": "ideas.WMS_INVENTORY",
"database.history.kafka.bootstrap.servers":"localhost:9092",
"database.history.kafka.topic":"schema-changes.inventory"
}
}
【问题讨论】：
标签： oracle apache-kafka apache-kafka-connect debezium