Clojurians Log v2
Clojure programming
Channels
Apps
jackdaw
https://github.com/FundingCircle/jackdaw
A King 2019-11-04T11:09:58.007Z
Hi, is there a way to know which topic a message came from when building a topology with multiple inputs?
2019-11-04T11:11:08.008Z
Only if you break out of the DSL and use the processor API. That gives you access to all the record metadata like topic-name, timestamp, partition etc.
A King 2019-11-04T11:11:42.008200Z
Okay, thanks
2019-11-04T21:52:32.010200Z
Would it be possible for the record metadata to be obtained from Kafka, and added as Clojure metadata to the message? I don't have enough (actually any) experience with Kafka or jackdaw to know if that is a bad/infeasible idea.