           batch (if (zero? max-segments) 
                       (<!! timeout-ch)
                       (->> (range max-segments)
-                           (keep (fn [_] (first (alts!! [read-ch timeout-ch] :priority true))))))]
+                           (keep (fn [_] (first (alts!! [retry-ch read-ch timeout-ch] :priority true))))))]
       (doseq [m batch]
         (let [message (:message m)]
-          (info "Read message in batch" message)
-
+          (trace "Read message in batch" task-id message)
           (when-not (= message :done)
             (swap! top-index max (:entry-id message))
             (swap! pending-indexes conj (:entry-id message))))

                          top-acked-id
                          pending-indexes
                          error
                          read-ch
                          commit-ch
                          shutdown-ch)))

    (throw (ex-info "Read log tasks must set :onyx/max-peers 1" task-map)))
  (when-not (:bookkeeper/password-bytes task-map)
    (throw (Exception. ":bookkeeper/password-bytes must be supplied")))

  (info "Inject read ledger resources:" (:onyx.core/task event))

  (let [{:keys [bookkeeper/ledger-start-id bookkeeper/ledger-end-id bookkeeper/zookeeper-ledgers-root-path
                bookkeeper/zookeeper-addr bookkeeper/deserializer-fn bookkeeper/no-recovery?] :as defaulted-task-map} 
