m0_37994675 2022-03-11 11:18 采纳率: 25%
浏览 143
已结题

kafka 出现 ERROR Error during poll on topic test SQL

问题遇到的现象和发生背景

kafka-connect-oracle 获取 oracle12c cdc 时

问题相关代码,请勿粘贴截图
运行结果及报错内容

[root@cyrus kafka]# ./bin/connect-standalone.sh config/connect-standalone.properties config/OracleSourceConnector.properties
Mar 11, 2022 11:14:36 AM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

[2022-03-11 11:14:53,784] ERROR Error during poll on topic test SQL :update "BIGUS"."TASS_DICT_INFO" set "DIC_NAME" = '数据接' where "ASSETS_CLASS" = 'apply_type_cls' and "DIC_NAME" = '数据' and "DIC_NO" = 'api' (com.ecer.kafka.connect.oracle.OracleSourceTask:298)
java.lang.NullPointerException
at com.ecer.kafka.connect.oracle.OracleSourceConnectorUtils.createDataSchema(OracleSourceConnectorUtils.java:351)
at com.ecer.kafka.connect.oracle.OracleSourceTask.poll(OracleSourceTask.java:269)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:163)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

我的解答思路和尝试过的方法
我想要达到的结果
  • 写回答

4条回答 默认 最新

  • IT民工金鱼哥 新星创作者: 运维技术领域 2022-03-11 14:26
    关注

    我也看得不太懂,不过看到是 更新数据 时有问题 ???
    你的场景是?

    评论

报告相同问题?

问题事件

  • 系统已结题 3月19日
  • 赞助了问题酬金5元 3月11日
  • 赞助了问题酬金5元 3月11日
  • 创建了问题 3月11日