Skip to content

Instantly share code, notes, and snippets.

@ztellman

ztellman/kafka-manifold.clj

Created September 20, 2016 18:54
Show Gist options
  • Save ztellman/7b60af41490e6fc9084abafc46297256 to your computer and use it in GitHub Desktop.
Save ztellman/7b60af41490e6fc9084abafc46297256 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka-manifold.clj
(defn kafka-sink []
(let [s (s/stream)]
(s/consume-async
(fn [msg]
(d/future (synchronous-put-to-kafka msg))))
s))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment