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-fn {:keys [topic-configs topic-kws callback-fn]
:as component})cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |