ERROR: publication "dbz_publication" does not exist
27 views
Skip to first unread message
Maciej Malecki
Jul 22, 2025, 6:54:15 AMJul 22
to debezium
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)
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)
Caused by: 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)
... 9 more
[2025-05-27 11:00:56,661] INFO [hq-debezium-connector|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:382)
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)
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)
Caused by: 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)
... 9 more
[2025-05-27 11:00:56,661] INFO [hq-debezium-connector|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:382)
jiri.p...@gmail.com
Jul 22, 2025, 6:56:12 AMJul 22
to debezium
Hi,
could you please share content of pg_publication that relates to the debezium_hq publication?
Thanks
Jiri
Maciej Malecki
Jul 23, 2025, 5:12:38 AMJul 23
to debezium
SELECT * FROM pg_publication
"pubname" "pubowner" "puballtables" "pubinsert" "pubupdate" "pubdelete" "pubtruncate"
"dbz_publication" "10" true true true true true
"pubname" "pubowner" "puballtables" "pubinsert" "pubupdate" "pubdelete" "pubtruncate"
"dbz_publication" "10" true true true true true
Reply all
Reply to author
Forward
0 new messages