Соединитель мойки JDBC для ClickHouse - PullRequest
Новая
       19

Соединитель мойки JDBC для ClickHouse

0 голосов

Можно ли передавать данные из Kafka topi c в таблицу Clickhouse через Jdbc Sink Connector? Все хорошо работает с Postgres. Но при попытке использовать Clickhouse (настройки идентичны) я получаю сообщение об ошибке:

org. apache .kafka.connect.errors.ConnectException: тип null (FLOAT32) не имеет сопоставления с тип столбца SQL базы данных в io.confluent.connect.jdb c .dialect.GenericDatabaseDialect.getSqlType (GenericDatabaseDialect. java: 1727) в io.confluent.connect.jdb c .dialect.DumnWrite c (GenericDatabaseDialect. java: 1643) по адресу io.confluent.connect.jdb c .dialect.GenericDatabaseDialect.lambda $ writeColumnsSpec $ 33 (GenericDatabaseDialect. java: 1632) по адресу io.conflub. 1020 * .util.ExpressionBuilder.append (ExpressionBuilder. java: 558) в io.confluent.connect.jdb c .util.ExpressionBuilder $ BasicListBuilder.of (ExpressionBuilder. java: 597) в io.confent. connect.jdb c .dialect.GenericDatabaseDialect.writeColumnsSpe c (GenericDatabaseDialect. java: 1634) в io.confluent.connect.jdb c .dialect.GenericDatabaseDialect.buildCreateTableStatement ricDatabaseDialect. java: 1557) в io.confluent.connect.jdb c .sink.DbStructure.create (DbStructure. java: 91) в io.confluent.connect.jdb c .sink.DbStructure. createOrAmendIfNeeded (DbStructure. java: 61) в io.confluent.connect.jdb c .sink.BufferedRecords.add (BufferedRecords. java: 121) в io.confluent.connect.jdb c .sink. JdbcDbWriter.write (JdbcDbWriter. java: 66) по адресу io.confluent.connect.jdb c .sink.JdbcSinkTask.put (JdbcSinkTask. java: 74) в орг. apache .kafconcon. .WorkerSinkTask.deliverMessages (WorkerSinkTask. java: 538) в орг. apache .kafka.connect.runtime.WorkerSinkTask.poll (WorkerSinkTask. java: 321) в орг. apache .kafka.connect .WorkerSinkTask.iteration (WorkerSinkTask. java: 224) в орг. apache .kafka.connect.runtime.WorkerSinkTask.execute (WorkerSinkTask. java: 192) в орг. apache .kafka.connect.untime .WorkerTask.doRun (WorkerTask. java: 177) в орг. apache .kafka.connect.runtime.WorkerTask.run (WorkerTask. java: 227) в java .util.concurrent.Executors $ Ru nnableAdapter.call (Executors. java: 511) в java .util.concurrent.FutureTask.run (FutureTask. java: 266) в java .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor. *: 1149) в java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) в java .lang.Thread.run (поток. java: 748)

Топи c схема: 

{
  "type": "record",
  "name": "name",
  "namespace": "name.space",
  "fields": [
    {
      "name": "brakeLinePressure",
      "type": "float"
    }
  ]
}
...