[2024-03-05 06:01:43,526] ERROR [Source Informix|task-0] Caught Exception (io.debezium.connector.informix.InformixStreamingChangeEventSource:206) java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:437) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5759) at com.informix.jdbc.IfxSqli.executeReadSmBlob(IfxSqli.java:5701) at com.informix.jdbc.IfxSmartBlob.IfxLoRead(IfxSmartBlob.java:731) at com.informix.stream.cdc.IfxCDCEngine.getRecord(IfxCDCEngine.java:323) at io.debezium.connector.informix.InformixCdcTransactionEngine.getRecord(InformixCdcTransactionEngine.java:70) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:180) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:39) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:195) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:138) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Suppressed: com.informix.stream.impl.IfxStreamException: Unable to end cdc capture at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:422) at com.informix.stream.cdc.IfxCDCEngine.unwatchTable(IfxCDCEngine.java:402) at com.informix.stream.cdc.IfxCDCEngine.close(IfxCDCEngine.java:470) at io.debezium.connector.informix.InformixCdcTransactionEngine.close(InformixCdcTransactionEngine.java:181) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:112) ... 9 more Caused by: java.sql.SQLException: Connection not established at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:370) at com.informix.jdbc.IfxStatement.(IfxStatement.java:138) at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:111) at com.informix.jdbc.IfxCallableStatement.(IfxCallableStatement.java:139) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:5913) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:2488) at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:409) ... 13 more Caused by: java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:386) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:392) at com.informix.jdbc.IfxSqli.handleSocketException(IfxSqli.java:7646) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2211) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5757) ... 14 more Caused by: java.io.IOException at com.informix.asf.IfxDataInputStream.readFully(IfxDataInputStream.java:140) at com.informix.asf.IfxDataInputStream.readSmallInt(IfxDataInputStream.java:411) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2185) ... 15 more [2024-03-05 06:01:43,529] ERROR [Source Informix|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52) java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:437) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5759) at com.informix.jdbc.IfxSqli.executeReadSmBlob(IfxSqli.java:5701) at com.informix.jdbc.IfxSmartBlob.IfxLoRead(IfxSmartBlob.java:731) at com.informix.stream.cdc.IfxCDCEngine.getRecord(IfxCDCEngine.java:323) at io.debezium.connector.informix.InformixCdcTransactionEngine.getRecord(InformixCdcTransactionEngine.java:70) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:180) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:39) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:195) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:138) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Suppressed: com.informix.stream.impl.IfxStreamException: Unable to end cdc capture at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:422) at com.informix.stream.cdc.IfxCDCEngine.unwatchTable(IfxCDCEngine.java:402) at com.informix.stream.cdc.IfxCDCEngine.close(IfxCDCEngine.java:470) at io.debezium.connector.informix.InformixCdcTransactionEngine.close(InformixCdcTransactionEngine.java:181) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:112) ... 9 more Caused by: java.sql.SQLException: Connection not established at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:370) at com.informix.jdbc.IfxStatement.(IfxStatement.java:138) at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:111) at com.informix.jdbc.IfxCallableStatement.(IfxCallableStatement.java:139) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:5913) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:2488) at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:409) ... 13 more Caused by: java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:386) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:392) at com.informix.jdbc.IfxSqli.handleSocketException(IfxSqli.java:7646) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2211) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5757) ... 14 more Caused by: java.io.IOException at com.informix.asf.IfxDataInputStream.readFully(IfxDataInputStream.java:140) at com.informix.asf.IfxDataInputStream.readSmallInt(IfxDataInputStream.java:411) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2185) ... 15 more [2024-03-05 06:01:43,530] WARN [Source Informix|task-0] Retry 1 of unlimited retries will be attempted (io.debezium.pipeline.ErrorHandler:125) [2024-03-05 06:01:43,531] INFO [Source Informix|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:273) [2024-03-05 06:01:43,531] INFO [Source Informix|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:425) [2024-03-05 06:01:43,896] WARN [Source Informix|task-0] Going to restart connector after 60 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask:279) [2024-03-05 06:01:43,897] INFO [Source Informix|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:127) [2024-03-05 06:01:43,898] INFO [Source Informix|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105) [2024-03-05 06:01:43,901] INFO [Source Informix|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:949) [2024-03-05 06:01:43,903] INFO [Source Informix|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:949) [2024-03-05 06:01:43,904] INFO [Source Informix|task-0] [Producer clientId=perf129_copy1_net_01-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1310) [2024-03-05 06:01:43,907] INFO [Source Informix|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693) [2024-03-05 06:01:43,907] INFO [Source Informix|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697) [2024-03-05 06:01:43,907] INFO [Source Informix|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703) [2024-03-05 06:01:43,907] INFO [Source Informix|task-0] App info kafka.producer for perf129_copy1_net_01-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-03-05 06:01:43,907] WARN [Source Informix|task-0] WorkerSourceTask{id=Source Informix-0} failed to poll records from SourceTask. Will retry operation. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:464) org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:63) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:207) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:39) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:195) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:138) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:437) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5759) at com.informix.jdbc.IfxSqli.executeReadSmBlob(IfxSqli.java:5701) at com.informix.jdbc.IfxSmartBlob.IfxLoRead(IfxSmartBlob.java:731) at com.informix.stream.cdc.IfxCDCEngine.getRecord(IfxCDCEngine.java:323) at io.debezium.connector.informix.InformixCdcTransactionEngine.getRecord(InformixCdcTransactionEngine.java:70) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:180) ... 9 more Suppressed: com.informix.stream.impl.IfxStreamException: Unable to end cdc capture at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:422) at com.informix.stream.cdc.IfxCDCEngine.unwatchTable(IfxCDCEngine.java:402) at com.informix.stream.cdc.IfxCDCEngine.close(IfxCDCEngine.java:470) at io.debezium.connector.informix.InformixCdcTransactionEngine.close(InformixCdcTransactionEngine.java:181) at io.debezium.connector.informix.InformixStreamingChangeEventSource.execute(InformixStreamingChangeEventSource.java:112) ... 9 more Caused by: java.sql.SQLException: Connection not established at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:370) at com.informix.jdbc.IfxStatement.(IfxStatement.java:138) at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:111) at com.informix.jdbc.IfxCallableStatement.(IfxCallableStatement.java:139) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:5913) at com.informix.jdbc.IfxSqliConnect.prepareCall(IfxSqliConnect.java:2488) at com.informix.stream.cdc.IfxCDCEngine.endCapture(IfxCDCEngine.java:409) ... 13 more Caused by: java.sql.SQLException: System or internal error at com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) at com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:386) at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:392) at com.informix.jdbc.IfxSqli.handleSocketException(IfxSqli.java:7646) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2211) at com.informix.jdbc.IfxSqli.doLoData(IfxSqli.java:5757) ... 14 more Caused by: java.io.IOException at com.informix.asf.IfxDataInputStream.readFully(IfxDataInputStream.java:140) at com.informix.asf.IfxDataInputStream.readSmallInt(IfxDataInputStream.java:411) at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2185) ... 15 more [2024-03-05 06:01:43,908] INFO [Source Informix|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:258) [2024-03-05 06:01:52,085] INFO [Source Informix|task-0|offsets] WorkerSourceTask{id=Source Informix-0} Committing offsets for 114 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask:228) [2024-03-05 06:01:52,089] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:02,089] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:12,090] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:15,654] INFO [Consumer clientId=connect-cluster--offsets, groupId=connect-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:15,785] INFO [Consumer clientId=connect-cluster--configs, groupId=connect-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:15,847] INFO [Worker clientId=connect-1, groupId=connect-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:15,938] INFO [Consumer clientId=connect-cluster--statuses, groupId=connect-cluster] Node -2 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:17,178] INFO [Producer clientId=connect-cluster--configs] Node -3 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:22,091] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:22,119] INFO [Producer clientId=connect-cluster--offsets] Node -2 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:24,567] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors HTTP/1.1" 200 38 "-" "ReactorNetty/1.1.6" 9 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,576] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix HTTP/1.1" 200 2218 "-" "ReactorNetty/1.1.6" 8 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,576] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination HTTP/1.1" 200 6537 "-" "ReactorNetty/1.1.6" 7 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,580] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination/status HTTP/1.1" 200 176 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,581] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix/status HTTP/1.1" 200 177 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,589] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix/config HTTP/1.1" 200 2115 "-" "ReactorNetty/1.1.6" 5 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,590] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination/config HTTP/1.1" 200 6434 "-" "ReactorNetty/1.1.6" 7 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,594] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix/tasks HTTP/1.1" 200 2242 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,596] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination/tasks HTTP/1.1" 200 6553 "-" "ReactorNetty/1.1.6" 2 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,600] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination/tasks/0/status HTTP/1.1" 200 59 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,601] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix/tasks/0/status HTTP/1.1" 200 59 "-" "ReactorNetty/1.1.6" 6 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,603] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Source%20Informix/topics HTTP/1.1" 200 97 "-" "ReactorNetty/1.1.6" 2 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:24,604] INFO 172.18.0.2 - - [05/Mar/2024:14:02:24 +0000] "GET /connectors/Sink%20Destination/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,219] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors HTTP/1.1" 200 38 "-" "ReactorNetty/1.1.6" 11 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,228] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination HTTP/1.1" 200 6537 "-" "ReactorNetty/1.1.6" 7 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,233] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination/status HTTP/1.1" 200 176 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,234] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix HTTP/1.1" 200 2218 "-" "ReactorNetty/1.1.6" 14 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,241] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix/status HTTP/1.1" 200 177 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,243] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination/config HTTP/1.1" 200 6434 "-" "ReactorNetty/1.1.6" 5 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,246] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix/config HTTP/1.1" 200 2115 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,250] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination/tasks HTTP/1.1" 200 6553 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,254] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix/tasks HTTP/1.1" 200 2242 "-" "ReactorNetty/1.1.6" 5 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,254] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination/tasks/0/status HTTP/1.1" 200 59 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,259] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix/tasks/0/status HTTP/1.1" 200 59 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,259] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Sink%20Destination/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:31,262] INFO 172.18.0.2 - - [05/Mar/2024:14:02:31 +0000] "GET /connectors/Source%20Informix/topics HTTP/1.1" 200 97 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:32,092] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:32,507] INFO [Producer clientId=connect-cluster--statuses] Node -3 disconnected. (org.apache.kafka.clients.NetworkClient:937) [2024-03-05 06:02:42,093] WARN [Source Informix|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349) [2024-03-05 06:02:43,912] INFO [Source Informix|task-0] Attempting to restart task. (io.debezium.connector.common.BaseSourceTask:250) [2024-03-05 06:02:43,914] INFO [Source Informix|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.informix.InformixSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1410) [2024-03-05 06:02:43,918] INFO [Source Informix|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig:1154) [2024-03-05 06:02:43,939] ERROR [Source Informix|task-0] WorkerSourceTask{id=Source Informix-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:210) java.lang.RuntimeException: Couldn't obtain database name at io.debezium.connector.informix.InformixConnection.retrieveRealDatabaseName(InformixConnection.java:102) at io.debezium.connector.informix.InformixConnection.(InformixConnection.java:70) at io.debezium.connector.informix.InformixConnectorTask.lambda$start$0(InformixConnectorTask.java:73) at io.debezium.jdbc.DefaultMainConnectionProvidingConnectionFactory.(DefaultMainConnectionProvidingConnectionFactory.java:16) at io.debezium.connector.informix.InformixConnectorTask.start(InformixConnectorTask.java:72) at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:251) at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:178) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:462) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:351) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:202) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:257) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:75) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.sql.SQLException: Only an administrative user can connect in administrative user mode. at com.informix.jdbc.IfxSqliConnect.(IfxSqliConnect.java:1348) at com.informix.jdbc.IfxDriver.connect(IfxDriver.java:167) at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:243) at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:875) at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:870) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:623) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:497) at io.debezium.connector.informix.InformixConnection.retrieveRealDatabaseName(InformixConnection.java:99) ... 17 more Caused by: com.informix.asf.IfxASFRemoteException: at com.informix.asf.Connection.recvConnectionResponse(Connection.java:589) at com.informix.asf.Connection.establishConnection(Connection.java:1418) at com.informix.asf.Connection.connect(Connection.java:333) at com.informix.asf.Connection.(Connection.java:325) at com.informix.jdbc.IfxSqliConnect.(IfxSqliConnect.java:1248) ... 25 more [2024-03-05 06:02:43,940] INFO [Source Informix|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:282) [2024-03-05 06:02:43,940] INFO [Source Informix|task-0] [Producer clientId=connector-producer-Source Informix-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1310) [2024-03-05 06:02:43,943] INFO [Source Informix|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693) [2024-03-05 06:02:43,944] INFO [Source Informix|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697) [2024-03-05 06:02:43,944] INFO [Source Informix|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703) [2024-03-05 06:02:43,944] INFO [Source Informix|task-0] App info kafka.producer for connector-producer-Source Informix-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-03-05 06:02:43,945] INFO [Source Informix|task-0] App info kafka.admin.client for connector-adminclient-Source Informix-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-03-05 06:02:43,947] INFO [Source Informix|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693) [2024-03-05 06:02:43,947] INFO [Source Informix|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697) [2024-03-05 06:02:43,947] INFO [Source Informix|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703) [2024-03-05 06:02:50,029] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors HTTP/1.1" 200 38 "-" "ReactorNetty/1.1.6" 6 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,036] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix HTTP/1.1" 200 2218 "-" "ReactorNetty/1.1.6" 5 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,039] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Sink%20Destination HTTP/1.1" 200 6537 "-" "ReactorNetty/1.1.6" 8 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,042] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix/status HTTP/1.1" 200 3204 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,045] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Sink%20Destination/status HTTP/1.1" 200 176 "-" "ReactorNetty/1.1.6" 5 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,048] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix/config HTTP/1.1" 200 2115 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,054] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Sink%20Destination/config HTTP/1.1" 200 6434 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,056] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix/tasks HTTP/1.1" 200 2242 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,062] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Sink%20Destination/tasks HTTP/1.1" 200 6553 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,062] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix/tasks/0/status HTTP/1.1" 200 3086 "-" "ReactorNetty/1.1.6" 4 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,065] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Sink%20Destination/tasks/0/status HTTP/1.1" 200 59 "-" "ReactorNetty/1.1.6" 3 (org.apache.kafka.connect.runtime.rest.RestServer:62) [2024-03-05 06:02:50,065] INFO 172.18.0.2 - - [05/Mar/2024:14:02:50 +0000] "GET /connectors/Source%20Informix/topics HTTP/1.1" 200 97 "-" "ReactorNetty/1.1.6" 2 (org.apache.kafka.connect.runtime.rest.RestServer:62)