Fork me on GitHub
#jackdaw
<
2019-04-16
>
Paco01:04:24

you can do something like

(defn build-topologies
  ""
  [builder topology-fn topics-process]
  (doseq [[topic-name] topics-to-process]
    (-> (j/kstream builder (get-topic-meta (config/topics) topic-name))
        (j/for-each! topic-fn)))
  builder)

Paco01:04:53

chain topologies being build with the builder however you want

Paco01:04:23

imagine a ton of nodes being built in parallel

cddr15:04:14

Hey @gphilipp, Thanks for mirroring this in zulip but I can't find the corresponding channel in the clojurians org. Would you expect it to be there?