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)

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

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

oracle数据库不同版本用的连接库可能存在差异,以前数据库升级版本遇到过后面换了对应链接库就好了。不知道你这个是不是这个情况

name=LITERAL_VALUES
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
#key.converter=io.confluent.connect.avro.AvroConverter
#value.converter=io.confluent.connect.avro.AvroConverter
key.serializer=io.confluent.kafka.serializers.KafkaAvroSerializer
value.serializer=io.confluent.kafka.serializers.KafkaAvroSerializer
connection.user=c##hamza
connection.password=admin
poll.interval.ms=3600000
tasks.max=1
table.whitelist=OWAIS
connection.url=jdbc:oracle:thin:@192.168.2.220:1521/orcl
mode=timestamp+incrementing
incrementing.column.name=ID
timestamp.column.name=MODIFIED
timestamp.delay.interval.ms=2
topic.prefix=LITERAL-VAL-

是不是你用的版本比较低,换最新的版本试试