当前位置: 首页 > 知识库问答 >
问题:

Kafka Connect:没有找到合适的驱动程序

符懿轩
2023-03-14

我正在使用JDBC接收器连接器尝试Kafka和Postgres接收器。

例外:

INFO Unable to connect to database on attempt 1/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider:91)
java.sql.SQLException: No suitable driver found for jdbc:postgresql://localhost:5432/casb
at java.sql.DriverManager.getConnection(DriverManager.java:689)
    at java.sql.DriverManager.getConnection(DriverManager.java:247)
    at io.confluent.connect.jdbc.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:85)
    at io.confluent.connect.jdbc.util.CachedConnectionProvider.getValidConnection(CachedConnectionProvider.java:68)
    at io.confluent.connect.jdbc.sink.JdbcDbWriter.write(JdbcDbWriter.java:56)
    at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:69)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:495)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:288)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:198)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:166)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
    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)

水槽特性:

name=test-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=fp_test
connection.url=jdbc:postgresql://localhost:5432/casb
connection.user=admin
connection.password=***
auto.create=true

我已经设置了< code > plugin . path =/usr/share/Java/Kafka-connect-JDBC

/usr/share/java/kafka-connect-jdbc我有以下文件:

Kafka-连接-jdbc-4.0.0.jarpostgresql-9.4-1206-jdbc41.jarsqlite-jdbc-3.8.11.2.jar和其他一些基本上与汇合物一起打包的罐子。

然后我下载了 postgres-jdbc 驱动程序 jar postgresql-42.2.2.jar,将其复制到同一文件夹中,然后重试。仍然是同样的例外。

请帮我解决这个问题。

共有1个答案

蒋弘致
2023-03-14

设置plugin。path=/usr/share/java和CLASSPATH=/usrs/share/java/kafka-connect-jdbc/

 类似资料:
  • 当我创建kafka jdbc源连接器(debezium连接器用于带有confluent-5.4.0的oracle)时,出现错误“没有找到适合jdbc: oracle: oci…”。 我的oracle版本是企业版发布11.2.0.4.0-64位生产,我尝试了不同的驱动程序jar,但得到了相同的异常。 我的jdk版本是: 我已经将 debezium-连接器-预言机添加到文件夹融合-5.4.0/shar

  • 试图连接到允许远程连接的免费mysql数据库主机,但我遇到了以下错误: 未找到适合jdbc的驱动程序:mysql://xx2-23-x1-2x1-172.compuxe-1.xmazonaws.com:3306 我使用下面的代码。 编辑 Stack Trace显示在下面:

  • 我正在尝试使用以下代码将我的JavaMaven项目(在Jetty服务器上运行)连接到Google Cloud MySQL数据库: 我已经在pom中包含了这两个依赖项。xml: 我要走了 JAVAsql。SQLException:找不到适合jdbc的驱动程序:mysql://google... 我不知道该怎么办。我假设依赖项应该处理将JDBC驱动程序添加到我的类路径。

  • 我试图编写一个连接到MySQL数据库的java程序。但是我得到了这个错误: 没有找到适合jdbc:mysql//localhost:3306/test的驱动程序 我已经安装了。我还是会犯这个错误。 这是我的程序:

  • 我已经花了3个小时试图让我的Java程序与我的Postgres服务器接口。我无法通过错误消息“没有找到适合jdbc:postgresql://localhost:5432/gis的驱动程序”。这是一个Bukkit插件,我正在使用IntelliJ IDEA。 代码: 我尝试过的事情: > 直接将jdbc文件内部添加到jar文件中 在IntelliJ项目中添加jdbc文件作为依赖项 切换到maven,

  • 我按照java程序编写 我编译了这个程序并创建了jar文件 Jar具有以下清单文件 还包含文件 /folder/postgresql-8.4-703.jdbc3.jar.我通过命令启动了Sample.jar 结果我收到了以下信息 我从地址为192.168.1.10的主机启动了该文件,在主机192.168.1.8上它正常运行。帮助消除错误。