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

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"
    }
}

假设连接信息(此处未提供(是正确的，我还确保.jar在

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

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

Answer 1

您得到的错误：

Query mode must be specified

告诉你问题:)您的配置中缺少mode。如果要每次都拉入表的全部内容，请使用 "mode":"bulk" 。有关更多详细信息，请参阅此文章。