Java NPE error DB2 AS 400 Kafka connect through Debezium

Arun Kumar7:26 AM
  
  
 
 
 
I am trying to connect to DB2 i Series AS400 through Kafka Connect - Debezium for CDC pull from DB2 tables and stuck at one point with below error. Tried all sorts of changes but could not make it work. Any one encountered this issue or what could have gone wrong or indicative of this issue?
DB2 properties file and error provided below.
[2022-01-21 22:29:50,043] ERROR Failed testing connection for
dbc:db2://ABCD:123/Servername with user 'ABC' (io.debezium.connector.db2.Db2Connector:84)
com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-104, SQLSTATE=42601,
SQLERRMC=;;<END-OF-STATEMENT>, DRIVER=3.68.61
at com.ibm.db2.jcc.am.gd.a(gd.java:749)
at com.ibm.db2.jcc.am.gd.a(gd.java:66)
at com.ibm.db2.jcc.am.gd.a(gd.java:135)
at com.ibm.db2.jcc.am.uo.c(uo.java:2780)
at com.ibm.db2.jcc.am.uo.d(uo.java:2768)
at com.ibm.db2.jcc.am.uo.a(uo.java:2217)
at com.ibm.db2.jcc.t4.bb.h(bb.java:141)
at com.ibm.db2.jcc.t4.bb.b(bb.java:41)
at com.ibm.db2.jcc.t4.p.a(p.java:32)
at com.ibm.db2.jcc.t4.vb.i(vb.java:145)
at com.ibm.db2.jcc.am.uo.ib(uo.java:2186)
at com.ibm.db2.jcc.am.uo.a(uo.java:3267)
at com.ibm.db2.jcc.am.uo.e(uo.java:1102)
at com.ibm.db2.jcc.am.uo.execute(uo.java:1081)
at io.debezium.jdbc.JdbcConnection.lambda$execute$2(JdbcConnection.java:433)
at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:450)
at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:427)
at io.debezium.connector.db2.Db2Connector.validateConnection(Db2Connector.java:80)
at io.debezium.connector.common.RelationalBaseSourceConnector.validate(RelationalBaseSourceConnector.java:54)
at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:375)
at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$1(AbstractHerder.java:326)
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)
[2022-01-21 22:29:50,050] INFO Connection gracefully closed
(io.debezium.jdbc.JdbcConnection:965)
[2022-01-21 22:29:50,052] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:354)
[2022-01-21 22:29:50,058] ERROR Failed to create job for kafka_2.12-2.6.3/config/connect- debezium-db2.properties (org.apache.kafka.connect.cli.ConnectStandalone:110)
[2022-01-21 22:29:50,059] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:121)
java.util.concurrent.ExecutionException: java.lang.NullPointerException
at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:115)
at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:99)
at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:118)
Caused by: java.lang.NullPointerException
at org.apache.kafka.connect.runtime.AbstractHerder.maybeAddConfigErrors(AbstractHerder.java:605)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:215)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.lambda$null$1(StandaloneHerder.java:201)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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)

DB2 Connect Properties
name=db2-connector
connector.class=io.debezium.connector.db2.Db2Connector
tasks.max=1
database.server.name=ABCD
database.hostname=ABCD
database.port=123
database.user=DB2username
database.password=DB2password
database.dbname=dbname
database.server.id=1
database.history.kafka.bootstrap.servers=localhost:9092
database.history.kafka.topic=db_f0006
table.include.list=DEVLIB.F0006
tombstones.on.delete=false
include.schema.changes=true