kafka sink jdbc连接器在现有表上不适用于db2

xam8gpfp  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(254)

我正在尝试创建一个jdbc接收器连接器,以便将数据从主题移动到db2中的现有表。
模式是myschema
表出错\u tb
题目是考试题目
但我得到了一个不可恢复的工人例外。有人能告诉我这里出了什么问题吗?我正在按建议在连接url中传递架构名称。

{
  "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
  "transforms.RenameField.renames": "FAC:locId",
  "connection.password": "password",
  "tasks.max": "1",
  "topics": "test_topic",
  "table.name.format ": "ERROR_TB",
  "transforms": " RenameField",
  "key.converter.schemas.enable": "false",
  "fields.whitelist": "createdTS,newMap",
  "auto.evolve": "false",
  "connection.user": "user",
  "transforms.RenameField.type": " org.apache.kafka.connect.transforms.ReplaceField$Value",
  "value.converter.schemas.enable": "false",
  "name": "sink-db2-test-topic-distributed",
  "auto.create": "false",
  "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  "connection.url": "jdbc:db2://db11.db.com:port/db11?currentSchema=mySchema",
  "insert.mode": "insert",
  "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  "pk.mode": "none"
}

以下是主题中的信息。
{“topic”:“test\u topic”,“key”:1234567,“value”:{“locid”:“factory name is here”,“createdts”:1518688814936,“newmap”:{}}
我得到的例外是:

org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
    at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:457)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:251)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:180)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:148)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:748)

暂无答案!

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

相关问题