Liking cljdoc? Tell your friends :D

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].
raw docstring

Subscriberclj

source

topology-builder-fnclj

(topology-builder-fn {:keys [topic-configs topic-kws callback-fn]
                      :as component})
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close