m0_37994675
2022-03-11 11:18
采纳率: 25%
浏览 97

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条回答 默认 最新

相关推荐 更多相似问题