diff --git a/pkg/replicator/pgreplicator/pg.go b/pkg/replicator/pgreplicator/pg.go
index ce9e2cc..a0c1967 100644
--- a/pkg/replicator/pgreplicator/pg.go
+++ b/pkg/replicator/pgreplicator/pg.go
@@ -290,7 +290,7 @@ func (p *pg) Pull(ctx context.Context, cc chan *changeset.Changeset) error {
 			p.queryLock.Unlock()
 
 			if isConnClosedErr(err) && p.queryConn.IsClosed() {
-				return
+				continue
 			}
 
 			if err != nil {