我想在 confluent 上使用 JDBC 连接器。当我开始使用 Confluent CLI 连接时它不起作用。

confluent local start connect

它给出了这个错误:

Caused by: java.sql.SQLException: No suitable driver found for jdbc:oracle:thin:@10.10.10.10:1954/MYSERVICE

我停止连接并手动启动 connect-distributed 或独立它给出相同的错误

./bin/connect-distributed etc/schema-registry/connect-avro-distributed.properties

但是when I set CLASSPATH然后上面的代码工作正常并将数据传输到 Oracle。

export CLASSPATH=/home/my_confluent/confluent-5.4.1/share/java/kafka-connect-jdbc/ojdbc6.jar

但我仍然无法对 connect 服务做同样的事情。

当我启动我的 confluent connect

confluent local start connect

它给出了同样的错误。

最佳答案

Confluent CLI 使用 Golang 在底层启动脚本，因此这可以解释为什么导出 Java 特定变量不起作用，但是，如果您 export CLASSPATH=/any/path/to/jdbc-drivers/*.jar，然后在同一终端进程中运行任何进程，它应该继承那些变量。

confluent local start connect 在内部调用一些 exec.command("connect-distributed") 函数，因此这是一个通过 kafka-run-class.sh, which does inherit the CLASSPATH variable 运行的 Java 方法调用

关于oracle - 无法使用 confluent CLI : java. sql.SQLException 设置 CLASSPATH:找不到适合 jdbc:oracle:thin 的驱动程序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60967565/