(driver driver opts)This driver collects the messages that appear on the internal repartition topics and ensures that we only output the final result by pushing the repartition messages back into the topology and filtering them out of the result.
This driver collects the messages that appear on the internal repartition topics and ensures that we only output the final result by pushing the repartition messages back into the topology and filtering them out of the result.
(flatten-output output)(repartition-topic? topic)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |