Clojure wrapper to kafka streams.
Clojure wrapper to kafka streams.
(clj-global-ktable global-ktable)
Makes a CljKTable object.
Makes a CljKTable object.
(clj-kgroupedstream kgroupedstream)
Makes a CljKGroupedStream object.
Makes a CljKGroupedStream object.
(clj-kgroupedtable kgroupedtable)
Makes a CljKGroupedTable object.
Makes a CljKGroupedTable object.
(clj-kstream kstream)
Makes a CljKStream object.
Makes a CljKStream object.
(clj-session-windowed-kstream windowed-kstream)
Makes a CljSessionWindowedKStream object.
Makes a CljSessionWindowedKStream object.
(clj-time-windowed-kstream windowed-kstream)
Makes a CljTimeWindowedKStream object.
Makes a CljTimeWindowedKStream object.
(suppress-config->suppressed {:keys [max-records max-bytes
until-time-limit-ms]})
(topic->consumed {:keys [key-serde value-serde]})
(topic->materialized {:keys [topic-name key-serde value-serde]})
(topic->produced {:keys [key-serde value-serde partition-fn]})
(topic->serialized {:keys [key-serde value-serde]})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close