(processor kstream processor-supplier-fn)(processor kstream processor-supplier-fn state-store-names)Creates a KStream with the processor supplied by processor-supplier-fn attached to the topology. The processor-supplier-fn should reify the org.apache.kafka.streams.processor.Processor IFace.
Creates a KStream with the processor supplied by processor-supplier-fn attached to the topology. The processor-supplier-fn should reify the org.apache.kafka.streams.processor.Processor IFace.
(processor-supplier processor-supplier-fn)Packages up a Clojure fn in a kstream processor supplier.
Packages up a Clojure fn in a kstream processor supplier.
(time-windows window-duration)(time-windows window-duration advance-by-duration)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 |