如何修复无法打开与 jdbc:oracle:thin 的连接：必须指定@ldap://etc\nQuery 模式

Question

我正在尝试使用 rest API.
创建 Kafka 连接源实例我不断收到上述异常。我post这个连接信息（不包括密码）

{
    "name": "example-connector",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "tasks.max": "10",
        "topic.prefix": "mytopic",
        "connection.url": "jdbc:oracle:thin:@exampleConnectionString,cn=OracleContext,dc=world",
        "connection.user": "example_user",
        "key.converter": "io.confluent.connect.avro.AvroConverter",
        "value.converter": "io.confluent.connect.avro.AvroConverter"
    }
}

假设连接信息（此处未提供）是正确的，我还确保

中的 ojdbc7.jar 驱动程序

usr/share/java/kafka-connect-jdbc/

我容器的目录（我尝试 post 消息的地方）。相同的连接信息允许我使用客户端应用程序连接到数据库。我错过了什么？

Answer 1

您得到的错误：

Query mode must be specified

告诉您问题 :) 您的配置中缺少 mode。如果你想每次都拉入 table 的全部内容，请使用 "mode":"bulk"。有关详细信息，请参阅 this article。

如何修复无法打开与 jdbc:oracle:thin 的连接：必须指定@ldap://etc\nQuery 模式

How to fix Couldn't open connection to jdbc:oracle:thin:@ldap://etc\nQuery mode must be specified

java

apache-kafka-connect