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?
@cddr https://clojurians.zulipchat.com/#narrow/stream/180378-slack-archive/topic/jackdaw