2024-08-08 15:41:57,953 INFO || starting connector task 2.7.0 [io.debezium.connector.db2as400.As400ConnectorTask] 2024-08-08 15:41:57,966 INFO || Loading the custom topic naming strategy plugin: io.debezium.connector.db2as400.HostnamePrefixNamingScheme [io.debezium.config.CommonConnectorConfig] 2024-08-08 15:41:59,247 INFO || No previous offsets found [io.debezium.connector.common.BaseSourceTask] 2024-08-08 15:41:59,247 INFO || previous offsets not found creating from config [io.debezium.connector.db2as400.As400ConnectorTask] 2024-08-08 15:41:59,540 INFO || create new as400 connection [io.debezium.connector.db2as400.As400RpcConnection] 2024-08-08 15:42:00,085 ERROR || ignoring dump folder null as it doesn't exist [io.debezium.ibmi.db2.journal.retrieve.RetrieveConfigBuilder] 2024-08-08 15:42:00,092 INFO || previous includes . , new includes .
[io.debezium.connector.db2as400.As400ConnectorTask] 2024-08-08 15:42:00,093 INFO || no new tables to stream [io.debezium.connector.db2as400.As400ConnectorTask] 2024-08-08 15:42:00,103 INFO || Requested thread factory for component As400RpcConnector, id = dataops.cdc.db2 named = SignalProcessor [io.debezium.util.Threads] 2024-08-08 15:42:00,106 INFO || Requested thread factory for component As400RpcConnector, id = dataops.cdc.db2 named = change-event-source-coordinator [io.debezium.util.Threads] 2024-08-08 15:42:00,106 INFO || Requested thread factory for component As400RpcConnector, id = dataops.cdc.db2 named = blocking-snapshot [io.debezium.util.Threads] 2024-08-08 15:42:00,107 INFO || Creating thread debezium-as400rpcconnector-dataops.cdc.db2-change-event-source-coordinator [io.debezium.util.Threads] 2024-08-08 15:42:00,110 INFO Db2As400_Server|dataops.cdc.db2|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] 2024-08-08 15:42:00,110 INFO Db2As400_Server|dataops.cdc.db2|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] 2024-08-08 15:42:00,114 INFO Db2As400_Server|dataops.cdc.db2|snapshot No previous offset has been found [io.debezium.connector.db2as400.As400SnapshotChangeEventSource] 2024-08-08 15:42:00,114 INFO Db2As400_Server|dataops.cdc.db2|snapshot According to the connector configuration only schema will be snapshotted [io.debezium.connector.db2as400.As400SnapshotChangeEventSource] 2024-08-08 15:42:00,114 INFO Db2As400_Server|dataops.cdc.db2|snapshot snapshotting skipped but fetching structure [io.debezium.connector.db2as400.As400SnapshotChangeEventSource] 2024-08-08 15:42:02,846 INFO Db2As400_Server|dataops.cdc.db2|snapshot Reading structure of schema '' [io.debezium.connector.db2as400.As400SnapshotChangeEventSource] 2024-08-08 15:42:11,633 INFO Db2As400_Server|dataops.cdc.db2|snapshot fetched 591 long names [io.debezium.connector.db2as400.As400JdbcConnection] 2024-08-08 15:42:12,552 INFO Db2As400_Server|dataops.cdc.db2|snapshot finished fetching structure [io.debezium.connector.db2as400.As400SnapshotChangeEventSource] 2024-08-08 15:42:12,555 INFO Db2As400_Server|dataops.cdc.db2|snapshot Snapshot ended with SnapshotResult [status=SKIPPED, offset=null] [io.debezium.pipeline.ChangeEventSourceCoordinator] 2024-08-08 15:42:12,563 INFO Db2As400_Server|dataops.cdc.db2|streaming SignalProcessor started. Scheduling it every 5000ms [io.debezium.pipeline.signal.SignalProcessor] 2024-08-08 15:42:12,563 INFO Db2As400_Server|dataops.cdc.db2|streaming Creating thread debezium-as400rpcconnector-dataops.cdc.db2-SignalProcessor [io.debezium.util.Threads] 2024-08-08 15:42:12,563 INFO Db2As400_Server|dataops.cdc.db2|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2024-08-08 15:42:12,564 INFO || Interrupted is shuttingdown: true [io.debezium.connector.db2as400.As400StreamingChangeEventSource] 2024-08-08 15:42:12,564 ERROR Db2As400_Server|dataops.cdc.db2|streaming Producer failure [io.debezium.pipeline.ErrorHandler] java.lang.NullPointerException: Cannot invoke "io.debezium.connector.db2as400.As400OffsetContext.getPosition()" because "offsetContext" is null at io.debezium.connector.db2as400.As400StreamingChangeEventSource.execute(As400StreamingChangeEventSource.java:150) at io.debezium.connector.db2as400.As400StreamingChangeEventSource.execute(As400StreamingChangeEventSource.java:43) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:312) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) 2024-08-08 15:42:15,127 ERROR || WorkerSourceTask{id=test-cdc-db2-.
-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:150) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.connector.db2as400.As400OffsetContext.getPosition()" because "offsetContext" is null at io.debezium.connector.db2as400.As400StreamingChangeEventSource.execute(As400StreamingChangeEventSource.java:150) at io.debezium.connector.db2as400.As400StreamingChangeEventSource.execute(As400StreamingChangeEventSource.java:43) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:312) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) ... 5 common frames omitted 2024-08-08 15:42:15,128 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2024-08-08 15:42:15,130 INFO || SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] 2024-08-08 15:42:15,131 INFO || Debezium ServiceRegistry stopped. [io.debezium.service.DefaultServiceRegistry] 2024-08-08 15:42:18,038 WARN || [Worker clientId=connect-localhost:8083, groupId=1] Close timed out with 1 pending requests to coordinator, terminating client connections [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]