在与Kafka Connect连接时,找不到适用于jdbc的合适驱动程序-Oracle

我正在尝试在独立模式下使用Oracle jdbc8(ojdbc8.jar)在Kafka中运行oracle源连接器。我已经从Oracle网站下载了汇合的jdbc jar和ojdbc8.jar。我已经在本地进行了测试,并且工作正常,但是在我们的测试环境中,它抛出了以下错误:

No suitable driver found for jdbc:oracle:thin:@x.x.x.x:yyyy:zzz for configuration Couldn't open connection to jdbc:oracle:thin:@x.x.x.x:yyyy:zzz

完整错误消息:

ERROR Failed to create job for xyz/xyz.properties (org.apache.kafka.connect.cli.ConnectStandalone:110)
[2020-03-11 13:13:32,085] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:121)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 2 error(s):
Invalid value java.sql.SQLException: No suitable driver found for jdbc:oracle:thin:@x.x.x.x:1521:xyz for configuration Couldn't open connection to jdbc:oracle:thin:@x.x.x.x:1521:xyz
Invalid value java.sql.SQLException: No suitable driver found for jdbc:oracle:thin:@x.x.x.x:1521:xyz for configuration Couldn't open connection to jdbc:oracle:thin:@x.x.x.x:1521:xyz

插件的路径也很好,因为它正在注册所有jar。我尝试了一些在线发现的修复程序,其中包括将插件路径放入CLAsspATH变量中。它不起作用,引发了与上述相同的错误。我也能够分别ping和telnet IP和端口。

我的连接器配置如下:

name=oracle-jdbc-connect
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:oracle:thin:@x.x.x.x:yyyy:zzz
connection.user=xyz
connection.password=xyz
query=SELECT cast(ID AS NUMber(7,0)) AS ID,NAME FROM sch.tbl
mode=incrementing
incrementing.column.name=ID
topic.prefix=topic-test
schema.pattern=sch
numeric.mapping=best_fit
dialect.name=OracleDatabaseDialect
timestamp.delay.interval.ms=5000
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false
decimal.handling.mode=double
include.schema.changes=false

此处给出的connection.user在Oracle中具有“只读”特权。这可以成为一个问题吗?

connect-standalone.properties文件如下:

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.file.filename=/tmp/connect.offsets
offset.flush.interval.ms=10000
rest.host.name=x.x.x.x
rest.port=8877 # Some random port
plugin.path=/home/plugins/,/usr/share/java,/usr/local/share/kafka/plugins

Oracle版本: 18c
Kafka版本: 2.3.0
Scala版本: 2.12.2

plugins.path: / home / plugins

插件路径结构:/ home / plugins / connectors / [文件夹,例如资产,文档,lib等],ojdbc8.jar。

在/ home / plugins / connectors / lib里面,我有kafka-connect-jdbc-5.4.0.jar文件。

flyzeor 回答:在与Kafka Connect连接时,找不到适用于jdbc的合适驱动程序-Oracle

您的ojdbc8.jar必须和Kafka Connect JDBC JAR放在同一文件夹中。

因此,如果Kafka Connect JDBC JAR位于/home/plugins/connectors/lib中,那么也将ojdbc8.jar放入其中。

,

如果使用的是Java11,则更新为ojdbc10。对于kafka,ojdbc8与java8兼容,而ojdbc10与java11兼容。

本文链接:https://www.f2er.com/2665934.html

大家都在问