kafka是否可以使用interclient.jar连接interbase数据库。我无法连接它在乌本杜系统，即使在正确的文件夹中放置它。
这是我创建连接器的post命令。
curl -X POST -H "Content-Type: application/json" --data "{ \"name\": \"ib_connector\",\"config\": { \"connector.class\": \"io.confluent.connect.jdbc.JdbcSourceConnector\", \"tasks.max\": 1,\"connection.url\": \"jdbc:interbase://remoteip:3050/TEST2.gdb?user=SYSDBA&password=masterkey\",\"mode\": \"timestamp+incrementing\", \"incrementing.column.name\": \"id\",\"timestamp.column.name\": \"modified\", \"topic.prefix\": \"test-interbase-\", \"poll.interval.ms\": 1000 } }" http://localhost:8083/connectors.我已经放置了jdbc连接器 interclient.jar 文件输入 /usr/share/java/kafka-connect-jdbc .
在 docker-compose.yml 插件路径设置为 CONNECT_PLUGIN_PATH:'/usr/share/java,/etc/kafka-connect/jars' .
我也有 .env 其中的文件 KAFKA_CONNECT_JARS_PATH=/usr/share/java/kafka-connect-jdbc/ 以及 CLASS_PATH=usr/share/java/kafka-connect-jdbc/ .
我得到的错误信息如下。
{"error_code":400,"message":"Connector configuration is invalid and contains the following 2 error(s):\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:interbase://remoteip:3050/TEST2?user=SYSDBA&password=masterkey for configuration Couldn't open connection to jdbc:interbase://remoteip:3050/TEST2?user=SYSDBA&password=masterkey\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:interbase://remoteip:3050/TEST2?user=SYSDBA&password=masterkey
1条答案
按热度按时间zpqajqem1#
如果您使用的是docker，那么将本地文件系统上的jar放入
/usr/share/java不会让docker在没有卷Map的情况下拿起它。为了避免混淆，我建议您将主机文件移到别处。KAFKA_CONNECT_JARS_PATH对融合的 Docker 形象也没有任何意义。在本地创建其他本地目录。将jdbcjar放入其中，然后向compose文件添加一个卷，以指向容器中的jdbc connect位置
哪里
ls /path/to/your_folder显示要使用的jdbc驱动程序，如果安装了java，则可以运行jar -tf /path/to/your_folder/example.jar验证是否有试图加载到该文件中的jdbc驱动程序类。当我尝试mssqljdbc驱动程序时，这个设置在我的repo中起作用了