     (let [[json-str rest-msg] (str/split s #"\n" 2)]
       (try (*parse-json-stream (conj acc (json/parse-string json-str keyword)) rest-msg)
            (catch com.fasterxml.jackson.core.JsonParseException e
-             (println "JSON ERROR WHILE PARSE" s)
+             #_(println "JSON ERROR WHILE PARSE" s)
              [s acc])))
     [s acc]))
 

      (update-version (:resource opts) (get-in res [:object :metadata :resourceVersion]))
      ;; sometimes version is compacted :(
      (if (and (= "ERROR" (:type res)) (= "Expired" (get-in res [:object :reason])))
        (do (println "OUTDATE version:" res)
            (reset-version (:resource opts))
            (retry))
        (do (println opts " for v:" (get-in res [:object :metadata :resourceVersion]))
            (println "->" (:handler opts))
            (u/*apply (:handler opts) {:env env :resource (k8s/resolve-secrets res)}))))
    [body :continue]))


        q (build-watch-query env opts)
        q (if v (assoc-in q [:query :resourceVersion] v) q)
        on-change (mk-on-change env opts #(do-watch env client opts))]
    #_(println "Start Watch " opts " from " v)
    (println "Start Watch ")
    (->> (http/request-stream client :get (:url q) on-change
                              :headers {"Authorization" (str "Bearer " (:kube-token env))}
                              :insecure? true
