diff --git a/base/dcp_common.go b/base/dcp_common.go
index ea3e7b3b14..22df4a0796 100644
--- a/base/dcp_common.go
+++ b/base/dcp_common.go
@@ -120,8 +120,8 @@ func NewDCPCommon(ctx context.Context, callback sgbucket.FeedEventCallbackFunc,
 }
 
 func (c *DCPCommon) dataUpdate(seq uint64, event sgbucket.FeedEvent) {
-	c.updateSeq(event.VbNo, seq, true)
 	shouldPersistCheckpoint := c.callback(event)
+	c.updateSeq(event.VbNo, seq, true)
 	if c.persistCheckpoints && shouldPersistCheckpoint {
 		c.incrementCheckpointCount(event.VbNo)
 	}