Нет записей от JDBC Source Connector - PullRequest
Новая
       9

Нет записей от JDBC Source Connector

0 голосов
/ 27 апреля 2018

Я загружаю ниже файл JSON с ./confluent load CRM_TEST -d /kafka/CRM_TEST.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" 
} 
}
...