2023-08-22 15:54:23,224 INFO Oracle|vk_nau28|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-22 15:54:24,482 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-22 15:54:25,099 INFO || [AdminClient clientId=connector-adminclient-vk_nau28_src-0] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-22 15:54:28,173 INFO || [Worker clientId=connect-1, groupId=ufo] Session key updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-22 15:54:50,901 INFO Oracle|vk_nau28|streaming Already applied 3 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-22 15:55:24,483 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] Hibernate: ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_NUMBER" decimal(19,0) NULL Hibernate: INSERT INTO "naument1"."vk_nau28_tbl_servicecall" ("ID","CREATION_DATE","CLAIM_TRANSFERDATE","TITLE","CLIENT_EMAIL","CLAIM_SUMRETURN","CLAIM_POSTADDRESS","NEW_NUMBER") VALUES (?,?,?,?,?,?,?,?) ON CONFLICT ("ID") DO UPDATE SET "CREATION_DATE"=EXCLUDED."CREATION_DATE","CLAIM_TRANSFERDATE"=EXCLUDED."CLAIM_TRANSFERDATE","TITLE"=EXCLUDED."TITLE","CLIENT_EMAIL"=EXCLUDED."CLIENT_EMAIL","CLAIM_SUMRETURN"=EXCLUDED."CLAIM_SUMRETURN","CLAIM_POSTADDRESS"=EXCLUDED."CLAIM_POSTADDRESS","NEW_NUMBER"=EXCLUDED."NEW_NUMBER" 2023-08-22 15:56:24,484 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-22 15:56:27,326 INFO Oracle|vk_nau28|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-22 15:57:20,518 INFO Oracle|vk_nau28|streaming Already applied 4 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-22 15:57:24,485 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] Hibernate: ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_VARCHAR" varchar(4000) NULL Hibernate: INSERT INTO "naument1"."vk_nau28_tbl_servicecall" ("ID","CREATION_DATE","CLAIM_TRANSFERDATE","TITLE","CLIENT_EMAIL","CLAIM_SUMRETURN","CLAIM_POSTADDRESS","NEW_NUMBER","NEW_VARCHAR") VALUES (?,?,?,?,?,?,?,?,?) ON CONFLICT ("ID") DO UPDATE SET "CREATION_DATE"=EXCLUDED."CREATION_DATE","CLAIM_TRANSFERDATE"=EXCLUDED."CLAIM_TRANSFERDATE","TITLE"=EXCLUDED."TITLE","CLIENT_EMAIL"=EXCLUDED."CLIENT_EMAIL","CLAIM_SUMRETURN"=EXCLUDED."CLAIM_SUMRETURN","CLAIM_POSTADDRESS"=EXCLUDED."CLAIM_POSTADDRESS","NEW_NUMBER"=EXCLUDED."NEW_NUMBER","NEW_VARCHAR"=EXCLUDED."NEW_VARCHAR" 2023-08-22 15:58:24,486 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-22 15:58:29,817 INFO Oracle|vk_nau28|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-22 15:58:39,969 INFO || [Producer clientId=connector-producer-vk_nau28_src-0] Resetting the last seen epoch of partition vk_nau28.DEBEZIUM.GBC_TBL_SERVICECALL_NC28-0 to 0 since the associated topicId changed from null to L8KhSJjcRFapFt0Zd5LfPg [org.apache.kafka.clients.Metadata] 2023-08-22 15:59:04,923 INFO Oracle|vk_nau28|streaming Already applied 5 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-22 15:59:10,964 INFO Oracle|vk_nau28|streaming Already applied 6 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-22 15:59:24,487 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 2 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-22 15:59:25,192 INFO || [AdminClient clientId=connector-adminclient-vk_nau28_src-0] Node 3 disconnected. [org.apache.kafka.clients.NetworkClient] Hibernate: ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL 2023-08-22 16:00:21,659 WARN || SQL Error: 0, SQLState: 42601 [org.hibernate.engine.jdbc.spi.SqlExceptionHelper] 2023-08-22 16:00:21,659 ERROR || ERROR: syntax error at or near "ADD" Position: 82 [org.hibernate.engine.jdbc.spi.SqlExceptionHelper] 2023-08-22 16:00:21,665 ERROR || Failed to process record: Failed to process a sink record [io.debezium.connector.jdbc.JdbcSinkConnectorTask] org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) 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: jakarta.persistence.PersistenceException: Converting `org.hibernate.exception.SQLGrammarException` to JPA `PersistenceException` : JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:165) at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:175) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:654) at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:205) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more Caused by: org.hibernate.exception.SQLGrammarException: JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.exception.internal.SQLStateConversionDelegate.convert(SQLStateConversionDelegate.java:89) at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:56) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:109) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:95) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:97) at org.hibernate.query.sql.internal.NativeNonSelectQueryPlanImpl.executeUpdate(NativeNonSelectQueryPlanImpl.java:78) at org.hibernate.query.sql.internal.NativeQueryImpl.doExecuteUpdate(NativeQueryImpl.java:820) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:643) ... 16 more Caused by: org.postgresql.util.PSQLException: ERROR: syntax error at or near "ADD" Position: 82 at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415) at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190) at org.postgresql.jdbc.PgPreparedStatement.executeUpdate(PgPreparedStatement.java:152) at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:1502) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:84) ... 19 more 2023-08-22 16:00:24,488 INFO || WorkerSourceTask{id=vk_nau28_src-0} Committing offsets for 1 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-22 16:00:33,238 INFO Oracle|vk_nau28|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-22 16:00:43,084 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors HTTP/1.1" 200 96 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,092 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,093 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,093 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,094 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,094 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,095 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,096 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,098 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,098 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,099 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,100 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,101 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,101 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,102 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 167 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,103 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,104 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,105 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,106 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,107 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,109 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,110 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,110 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,111 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,111 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,112 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,113 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,115 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,115 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,116 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,117 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,118 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,119 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,121 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,121 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,122 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:43,122 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:43 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,933 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors HTTP/1.1" 200 96 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,937 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,938 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,940 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,940 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,941 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,941 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,942 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,944 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,945 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,945 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 167 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,945 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,946 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,946 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,946 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,949 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,950 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,951 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,951 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,952 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,952 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,954 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,955 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,956 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,958 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,958 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,959 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,959 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,960 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,961 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,962 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,965 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,965 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,965 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,965 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau28_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,967 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:00:44,969 INFO || 10.0.18.18 - - [22/Aug/2023:13:00:44 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:21,665 ERROR || WorkerSinkTask{id=vk_nau28_sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: JDBC sink connector failure [org.apache.kafka.connect.runtime.WorkerSinkTask] org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) 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: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: jakarta.persistence.PersistenceException: Converting `org.hibernate.exception.SQLGrammarException` to JPA `PersistenceException` : JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:165) at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:175) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:654) at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:205) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more Caused by: org.hibernate.exception.SQLGrammarException: JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.exception.internal.SQLStateConversionDelegate.convert(SQLStateConversionDelegate.java:89) at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:56) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:109) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:95) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:97) at org.hibernate.query.sql.internal.NativeNonSelectQueryPlanImpl.executeUpdate(NativeNonSelectQueryPlanImpl.java:78) at org.hibernate.query.sql.internal.NativeQueryImpl.doExecuteUpdate(NativeQueryImpl.java:820) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:643) ... 16 more Caused by: org.postgresql.util.PSQLException: ERROR: syntax error at or near "ADD" Position: 82 at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415) at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190) at org.postgresql.jdbc.PgPreparedStatement.executeUpdate(PgPreparedStatement.java:152) at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:1502) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:84) ... 19 more 2023-08-22 16:01:21,666 ERROR || WorkerSinkTask{id=vk_nau28_sink-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: Exiting WorkerSinkTask due to unrecoverable exception. at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:618) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) 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: org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) ... 11 more Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: jakarta.persistence.PersistenceException: Converting `org.hibernate.exception.SQLGrammarException` to JPA `PersistenceException` : JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:165) at org.hibernate.internal.ExceptionConverterImpl.convert(ExceptionConverterImpl.java:175) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:654) at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:205) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more Caused by: org.hibernate.exception.SQLGrammarException: JDBC exception executing SQL [ALTER TABLE "naument1"."vk_nau28_tbl_servicecall" ADD "NEW_TS" timestamp(6) NULL ADD "NEW_DATE" timestamp(6) NULL] at org.hibernate.exception.internal.SQLStateConversionDelegate.convert(SQLStateConversionDelegate.java:89) at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:56) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:109) at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:95) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:97) at org.hibernate.query.sql.internal.NativeNonSelectQueryPlanImpl.executeUpdate(NativeNonSelectQueryPlanImpl.java:78) at org.hibernate.query.sql.internal.NativeQueryImpl.doExecuteUpdate(NativeQueryImpl.java:820) at org.hibernate.query.spi.AbstractQuery.executeUpdate(AbstractQuery.java:643) ... 16 more Caused by: org.postgresql.util.PSQLException: ERROR: syntax error at or near "ADD" Position: 82 at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415) at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190) at org.postgresql.jdbc.PgPreparedStatement.executeUpdate(PgPreparedStatement.java:152) at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:1502) at org.hibernate.sql.exec.internal.StandardJdbcMutationExecutor.execute(StandardJdbcMutationExecutor.java:84) ... 19 more 2023-08-22 16:01:21,666 INFO || Closing session. [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-22 16:01:21,666 INFO || Closing the session factory [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-22 16:01:21,668 INFO || [Consumer clientId=connector-consumer-vk_nau28_sink-0, groupId=connect-vk_nau28_sink] Revoke previously assigned partitions vk_nau28.DEBEZIUM.GBC_TBL_SERVICECALL_NC28-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-22 16:01:21,668 INFO || [Consumer clientId=connector-consumer-vk_nau28_sink-0, groupId=connect-vk_nau28_sink] Member connector-consumer-vk_nau28_sink-0-8d0d3aed-2243-45b8-ae89-e098cc6d04bf sending LeaveGroup request to coordinator broker2:29092 (id: 2147483645 rack: null) due to the consumer is being closed [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-22 16:01:21,668 INFO || [Consumer clientId=connector-consumer-vk_nau28_sink-0, groupId=connect-vk_nau28_sink] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-22 16:01:21,668 INFO || [Consumer clientId=connector-consumer-vk_nau28_sink-0, groupId=connect-vk_nau28_sink] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-22 16:01:21,718 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-22 16:01:21,718 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-22 16:01:21,718 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-22 16:01:21,719 INFO || App info kafka.consumer for connector-consumer-vk_nau28_sink-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-22 16:01:28,902 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors HTTP/1.1" 200 96 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,910 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,911 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,912 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,914 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,915 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,915 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,916 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,916 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,918 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,920 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,921 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,922 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,923 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,924 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,924 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,925 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,925 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,927 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,928 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,930 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,931 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,932 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,933 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,933 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,934 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,937 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,937 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,937 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,937 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,940 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,942 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,944 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,946 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,947 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,948 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:01:28,950 INFO || 10.0.18.150 - - [22/Aug/2023:13:01:28 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:02:35,407 INFO Oracle|vk_nau28|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-22 16:03:48,930 INFO || [AdminClient clientId=ufo--shared-admin] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-22 16:03:54,351 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors HTTP/1.1" 200 96 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,359 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,360 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,361 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,361 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,361 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,362 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,364 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,364 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,366 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,368 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,368 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,370 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,370 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,373 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,374 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 11 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,374 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,375 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,378 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,380 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,381 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,383 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,383 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,384 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,384 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,385 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,386 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,387 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,390 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,392 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,393 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,394 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,395 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,396 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau28_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,398 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 11 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,400 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:54,401 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:54 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:56,210 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:56 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:56,210 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:56 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:56,212 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:56 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-22 16:03:56,212 INFO || 10.0.18.18 - - [22/Aug/2023:13:03:56 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer]