ERROR: publication does not exist" even though the publication does exist

20 views

Skip to first unread message

Maciej Malecki

unread,

Jul 22, 2025, 6:54:15 AMJul 22

to debe...@googlegroups.com

Hi, I'm having a problem with the Postgres source connector. The connector reports the error "ERROR: publication "dbz_publication" does not exist" even though the publication does exist.

For now, we'll just delete the slot, but this will result in some data being lost and omitted.

Have you encountered this error before? Do you know how to fix it?

[2025-05-27 11:00:56,228] ERROR [hq-debezium-connector|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)

org.postgresql.util.PSQLException: ERROR: publication "dbz_publication" does not exist

Where: slot "debezium_hq", output plugin "pgoutput", in the change callback, associated LSN E5C/FB00B130

at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)

at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1299)

at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1198)

at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:44)

at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:160)

at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:125)

at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:82)

at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:622)

at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:217)

at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:179)

at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42)

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:840)

[2025-05-27 11:00:56,230] WARN [hq-debezium-connector|task-0] Retry 1 of unlimited retries will be attempted (io.debezium.pipeline.ErrorHandler:125)

[2025-05-27 11:00:56,246] INFO [hq-debezium-connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:983)

[2025-05-27 11:00:56,251] INFO [hq-debezium-connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:983)

[2025-05-27 11:00:56,252] INFO [hq-debezium-connector|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:313)

[2025-05-27 11:00:56,252] INFO [hq-debezium-connector|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:465)

[2025-05-27 11:00:56,584] WARN [hq-debezium-connector|task-0] Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask:403)

[2025-05-27 11:00:56,588] INFO [hq-debezium-connector|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:127)

[2025-05-27 11:00:56,607] INFO [hq-debezium-connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:983)

[2025-05-27 11:00:56,607] INFO [hq-debezium-connector|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105)

[2025-05-27 11:00:56,660] INFO [hq-debezium-connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:983)

[2025-05-27 11:00:56,660] WARN [hq-debezium-connector|task-0] WorkerSourceTask{id=hq-debezium-connector-0} failed to poll records from SourceTask. Will retry operation. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:467)

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.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:182)