jackdaw 2019-04-16

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)

chain topologies being build with the builder however you want

imagine a ton of nodes being built in parallel

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?