diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java
index eb19ae68c..1d219607b 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java
@@ -116,6 +116,7 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
                         LOGGER.trace("Received empty message");
                         lastCompletelyProcessedLsn = lsn;
                         offsetContext.updateWalPosition(lsn, lastCompletelyProcessedLsn, null, null, null, taskContext.getSlotXmin(connection));
+                        maybeWarnAboutGrowingWalBacklog(false);
                         dispatcher.dispatchHeartbeatEvent(offsetContext);
                         return;
                     }