我正在尝试创建一个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)
暂无答案!
目前还没有任何答案,快来回答吧!