waterfall

waterfall copied to clipboard

Some messages might not be committed on consumer .close

1

## Problem When `out-sink` is closed via: ```clojure (ms/on-closed out-sink (fn [] @(actor [::close]))) ``` the consumer is closed right away. The problem is that when the `out-sink` got closed,...

skydread1

Reduce the frequency of commits

1

# Purpose Waterfall consumes from the topic and only commits once after processing all the consumed data. In this case, if there is a lot of data in the topic,...

JackSho