在连接Kafka Connect时，没有找到适合jdbc-Oracle的驱动程序

Question

我正在尝试在独立模式下使用OracleJDBC8（ojdbc8.jar）在Kafka中运行oracle源代码连接器。我已经下载了confluent的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

连接。不过，此处提供的用户在Oracle中具有“只读”权限。这会是个问题吗

独立连接。属性文件如下所示：

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

插件。路径：/home/插件

插件路径结构： /home/plugins/connectors/[文件夹，如资产，文档，库等]，ojdbc8.jar.

在/home/plugins/connectors/lib内部，我有kafka-connect-jdbc-5.4.0。jar文件。

Answer 1

如果您使用的是java11，请更新到ojdbc10。对于kafka，ojdbc8与java8兼容，ojdbc10与java11兼容。

Answer 2

您的ojdbc8.jar需要与Kafka Connect JDBC JAR位于同一文件夹中。

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