Clojurians Log v2

hey all, curious if there is advice for instrumenting an transducers and async pipelines? i have a some code like this but i'm not sure what's the best way to instrument something roughly like this:

(def in (my-kafka-steam))
(def out (my-database))
(def xf (comp (map foo) (map bar) (filter baz?)))
(def pipeline (async/pipeline-blocking 10 out xf in))