问题遇到的现象和发生背景
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)