java - 如何修复无法打开与 jdbc 的连接 :oracle:thin:@ldap://etc\nQuery mode must be specified

Question

我正在尝试使用 REST API 创建 Kafka-connect 源实例。
我不断收到上述异常。 我发布此连接信息(不包括密码)

{
    "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/

我的容器的目录(我尝试在其中发布消息)。 相同的连接信息允许我使用客户端应用程序连接到数据库。我错过了什么？

Answer 1

您收到的错误:

必须指定查询模式

告诉你问题:)你的配置中缺少mode。如果您想每次提取表格的全部内容，请使用"mode":"bulk"。欲了解更多详情，请参阅this article .