ERROR 1: 2024-12-31 16:46:01,300 INFO || [task-thread-relation_cdc_server_1874013356035538945_1871754362766819329-0hread] Debezium ServiceRegistry stopped. [io.debezium.service.DefaultServiceRegistry] 2024-12-31 16:46:01,300 INFO || [task-thread-relation_cdc_server_1874013356035538945_1871754362766819329-0hread] SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] 2024-12-31 16:46:01,299 INFO || [task-thread-relation_cdc_server_1874013356035538945_1871754362766819329-0hread] Stopping down connector [io.debezium.connector.common.BaseSourceTask] ... 9 more at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:179) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:217) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:703) at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:82) at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:125) at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:160) at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:44) at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1198) at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1299) at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) Where: slot "relation_cdc_server_1874013356035538945_1871754362766819329", output plugin "pgoutput", in the change callback, associated LSN 0/178B9108 Caused by: org.postgresql.util.PSQLException: ERROR: publication "relation_cdc_server_1871754362766819329" does not exist at java.base/java.lang.Thread.run(Thread.java:1583) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:324) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:182) at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. 2024-12-31 16:46:01,299 ERROR || [task-thread-relation_cdc_server_1874013356035538945_1871754362766819329-0hread] WorkerSourceTask{id=relation_cdc_server_1874013356035538945_1871754362766819329-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] ERROR2: 2024-12-31 16:17:39,131 INFO || [task-thread-relation_cdc_server_1874006022005587969_1871754362766819329-0hread] Debezium ServiceRegistry stopped. [io.debezium.service.DefaultServiceRegistry] 2024-12-31 16:17:39,130 INFO || [task-thread-relation_cdc_server_1874006022005587969_1871754362766819329-0hread] SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] 2024-12-31 16:17:39,130 INFO || [task-thread-relation_cdc_server_1874006022005587969_1871754362766819329-0hread] Stopping down connector [io.debezium.connector.common.BaseSourceTask] ... 9 more at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:179) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:217) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:703) at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:82) at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:125) at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:160) at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:44) at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1198) at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1299) at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) Where: slot "relation_cdc_server_1874006022005587969_1871754362766819329", output plugin "pgoutput", in the truncate callback, associated LSN 0/1787A6D0 Caused by: org.postgresql.util.PSQLException: ERROR: publication "relation_cdc_server_1871754362766819329" does not exist at java.base/java.lang.Thread.run(Thread.java:1583) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:324) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:182) at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. 2024-12-31 16:17:39,130 ERROR || [task-thread-relation_cdc_server_1874006022005587969_1871754362766819329-0hread] WorkerSourceTask{id=relation_cdc_server_1874006022005587969_1871754362766819329-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]