时间戳

首页 > 解决方案 > 没有来自 JDBC 源连接器的记录

apache-kafka - 没有来自 JDBC 源连接器的记录

问题描述

我使用 ./confluent load CRM_TEST -d /kafka/CRM_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" 
} 
}

标签： apache-kafkaapache-kafka-connectconfluent-platform

解决方案

推荐阅读