Async consumer commit operation is susceptible to WakeupException about kinsky HOT 8 CLOSED

(put! control-ch {:op :pause :topic-partitions topic-partitions})
(do-something-that-takes-a-few-hundred-milliseconds)
(put! control-ch {:op :commit})
(put! control-ch {:op :resume})

(put! control-ch {:op :pause :topic-partitions topic-partitions})
(do-something-that-takes-a-few-hundred-milliseconds)
(put! control-ch {:op :commit})
(Thread/sleep 1000)
(put! control-ch {:op :resume})

  ;; Assuming a topic "test" with 4 partitions

  (def t "test")
  (def nparts 4)
  (def parts (vec (for [i (range nparts)] {:topic t :partition i})))
  (def gid (str "testgroup-" (rand-int 1000)))

  (Thread/setDefaultUncaughtExceptionHandler
   (reify Thread$UncaughtExceptionHandler
     (uncaughtException [_ thread e]
       (println (pr-str e)))))

  (require '[kinsky.client :as client] '[kinsky.async :as async] '[clojure.core.async :as a] '[clojure.pprint :refer [pprint]])

  (let [[out ctl] (async/consumer {:bootstrap.servers "localhost:9092" :group.id gid} :string :string)] (def out out) (def ctl ctl))
  (a/go (loop [] (pprint (a/<! out)) (recur)))

  (a/put! ctl {:op :subscribe :topic t})

  (do
    (println "pause")
    (a/put! ctl {:op :pause :topic-partitions parts})
    (println "commit")
    (a/put! ctl {:op :commit})
    (println "resume")
    (a/put! ctl {:op :resume :topic-partitions parts}))