我用./confluent load crm\u test-d/kafka/crm\u test.json加载下面的json文件,然后有20秒左右的延迟,然后没有提示任何消息,我假设它已成功添加。我检查了连接日志,没有看到任何条目,源代码没有创建,主题也没有创建。这里会发生什么
{
"name":"CRMMASTP_SOURCE",
"config":{
"connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max":"1",
"topic.prefix":"CRMMASTP_TOPIC",
"connection.url":"jdbc:as400://<IP_ADDRESS>:<PORT>/<DATABASE>",
"connection.user":"unifi_srvc",
"connection.password":"weblogin",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://localhost:8081",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://localhost:8081",
"mode": "bulk",
"query": "SELECT * FROM DATABASE.TABLE limit 10",
"poll.interval.ms": "60000",
"batch.max.rows": "10000",
"table.types": "TABLE",
"plugin.path":"/confluent-4.1.0/share/java"
}
}
暂无答案!
目前还没有任何答案,快来回答吧!