Log LastOffset when logging start of SyncFlow

flow/activities/flowable.go

@@ -287,7 +287,6 @@ func (a *FlowableActivity) SyncFlow(
 	}
 	defer connectors.CloseConnector(ctx, dstConn)
 
-	logger.Info("pulling records...")
 	tblNameMapping := make(map[string]model.NameAndExclude, len(options.TableMappings))
 	for _, v := range options.TableMappings {
 		tblNameMapping[v.SourceTableIdentifier] = model.NewNameAndExclude(v.DestinationTableIdentifier, v.Exclude)
@@ -315,6 +314,7 @@ func (a *FlowableActivity) SyncFlow(
 	if err != nil {
 		return nil, err
 	}
+	logger.Info("pulling records...", slog.Int64("LastOffset", lastOffset))
 
 	// start a goroutine to pull records from the source
 	recordBatch := model.NewCDCRecordStream()