diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index bf7f9fd678..4924627fd9 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -299,6 +299,10 @@ func (a *FlowableActivity) SyncFlow(
 			return nil, err
 		}
 		defer connectors.CloseConnector(ctx, srcConn)
+
+		if err := srcConn.SetupReplConn(ctx); err != nil {
+			return nil, err
+		}
 	} else {
 		srcConn, err = a.waitForCdcCache(ctx, sessionID)
 		if err != nil {