Kafka Connect JDBC 源连接器 - java.sql.SQLException：ORA-01005：给出的密码为空；登录被拒绝

Question

我正在使用 Kafka 同步来自 2 个不同数据库的数据。但是，当运行 Kafka Connect 到 oracle-source-connector 文件时，出现错误： java.sql.SQLException: ORA-01005: null password given;登录被拒绝。

这是我的 oracle-source-connector 文件的详细信息

name=oracle-source-connector
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:oracle:thin:@//x.x.x.x:xxxx/khldbdev
connection.user=khldev
connection.password=khldev
table.whitelist=TABLE_TEST
mode=incrementing
incrementing.column.name=ID
topic.prefix=oracle_TABLE_TEST

我的oracle DB仍然使用该帐户，密码没有问题。我还为数据库下载了足够的 JDBC。我不明白为什么当kafka运行到该文件时它会报告错误。

提前致谢。

Answer 1

您可以尝试一些方法来进一步分类此问题

1. 检查放置在工作人员正确指向的正确目录中的源连接器属性文件
2. 检查任何其他数据库客户端进行连接测试
3. 这是当未从 .properties 文件中正确读取密码字段时通常会发生的一般错误。

此外，如果属性文件出现问题，您可以尝试类似于以下的操作（删除不需要的属性）。

curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{
     "name": "jdbc_source_mysql_01",
     "config": {
             "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
             "connection.url": "jdbc:mysql://mysql:3306/test",
             "connection.user": "connect_user",
             "connection.password": "connect_password",
             "topic.prefix": "mysql-01-",
             "poll.interval.ms" : 3600000,
             "table.whitelist" : "test.accounts",
             "mode":"bulk",
             "transforms":"createKey,extractInt",
             "transforms.createKey.type":"org.apache.kafka.connect.transforms.ValueToKey",
             "transforms.createKey.fields":"id",
             "transforms.extractInt.type":"org.apache.kafka.connect.transforms.ExtractField$Key",
             "transforms.extractInt.field":"id"
             }
     }'