Конфлюентный соединитель jdbc Невозможно выполнять инкрементные запросы, используя столбцы отметок времени - PullRequest
Новая
       18

Конфлюентный соединитель jdbc Невозможно выполнять инкрементные запросы, используя столбцы отметок времени

0 голосов
/ 12 декабря 2018

Загрузка соединителя: 

{
  "name": "jdbc-source-test",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "connection.url": "jdbc:mysql://localhost:3306/test?user=root&password=password",
    "table.whitelist":"test",
    "mode": "timestamp",
    "timestamp.column.name":"create_time",
    "topic.prefix": "test-mysql-jdbc-",
    "name":"jdbc-source-test"
  }
}

Поместить следующее сообщение в журнал: 

[2018-12-12 17:33:14,225] ERROR WorkerSourceTask{id=jdbc-source-test-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177)
org.apache.kafka.connect.errors.ConnectException: Cannot make incremental queries using timestamp columns [create_time] on `test`.`test` because all of these columns nullable.

То, что я предлагаю, не работает, потому что этот столбец имеет тип bigint (20).Есть ли обходные пути для этого?Конфлюэнтная версия - 5.0.1.

...