Liking cljdoc? Tell your friends :D
Clojure only.
rp.jackdaw.subscriber
A Processor component that simply consumes from one or more topics and calls a callback for each record.
Like Processor it takes app-config and topic-registry.
Unlike Processor instead of a topology-builder-fn it takes:
topic-kws: a collection of keywords identifying topics to consume.
callback-fn: a function that's called for each record; it's passed a map with the keys [:k :v :component].
A Processor component that simply consumes from one or more topics and calls a callback for each record. Like `Processor` it takes `app-config` and `topic-registry`. Unlike `Processor` instead of a `topology-builder-fn` it takes: `topic-kws`: a collection of keywords identifying topics to consume. `callback-fn`: a function that's called for each record; it's passed a map with the keys [:k :v :component].
topology-builder-fnclj
(topology-builder-fn {:keys [topic-configs topic-kws callback-fn]
:as component})cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close