是否可以通过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"
}
]
}
暂无答案!
目前还没有任何答案,快来回答吧!