jdbc​下沉​clickhouse连接器

6mzjoqzu  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(343)

是否可以通过jdbc将kafka主题中的数据传输到clickhouse表中​下沉​连接器?博士后一切都很好。但是当尝试使用clickhouse(设置相同)时,我得到错误:
org.apache.kafka.connect.errors.connectexception:null(float32)类型没有Map到io.confluent.connect.jdbc.dialect.genericdatabasedialect.getsqltype(genericdatabasedialect)处的sql数据库列类型。java:1727)at io.confluent.connect.jdbc.dialect.genericdatabasedialect.writecolumnspec(genericdatabasedialect。java:1643)在io.confluent.connect.jdbc.dialect.genericdatabasedialect.lambda$writecolumnsspec$33(genericdatabasedialect。java:1632)在io.confluent.connect.jdbc.util.expressionbuilder.append(expressionbuilder。java:558)在io.confluent.connect.jdbc.util.expressionbuilder$basiclistbuilder.of(expressionbuilder。java:597)在io.confluent.connect.jdbc.dialect.genericdatabasedialect.writecolumnsspec(genericdatabasedialect。java:1634)在io.confluent.connect.jdbc.dialect.genericdatabasedialect.buildcreatetablestatement(genericdatabasedialect。java:1557)at io.confluent.connect.jdbc.sink.dbstructure.create(dbstructure。java:91)在io.confluent.connect.jdbc.sink.dbstructure.createoramendifnecessary(dbstructure。java:61)at io.confluent.connect.jdbc.sink.bufferedrecords.add(bufferedrecords。java:121)在io.confluent.connect.jdbc.sink.jdbcdbwriter.write(jdbcdbwriter。java:66)at io.confluent.connect.jdbc.sink.jdbcsinktask.put(jdbcsinktask。java:74)在org.apache.kafka.connect.runtime.workersinktask.delivermessages(workersinktask。java:538)在org.apache.kafka.connect.runtime.workersinktask.poll(workersinktask。java:321)在org.apache.kafka.connect.runtime.workersinktask.iteration(workersinktask。java:224)在org.apache.kafka.connect.runtime.workersinktask.execute(workersinktask。java:192)在org.apache.kafka.connect.runtime.workertask.dorun(工作任务。java:177)在org.apache.kafka.connect.runtime.workertask.run(workertask。java:227)在java.util.concurrent.executors$runnableadapter.call(executors。java:511)在java.util.concurrent.futuretask.run(futuretask。java:266)在java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1149)在java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:624)在java.lang.thread.run(线程。java:748)
主题架构:

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题