jackdaw

https://github.com/FundingCircle/jackdaw
2019-04-16T01:45:24.004500Z

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)

2019-04-16T01:45:53.005Z

chain topologies being build with the builder however you want

2019-04-16T01:46:23.005300Z

imagine a ton of nodes being built in parallel

2019-04-16T15:41:14.007800Z

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?