Liking cljdoc? Tell your friends :D

jackdaw.streams.interop

Clojure wrapper to kafka streams.

Clojure wrapper to kafka streams.
raw docstring

clj-global-ktableclj

(clj-global-ktable global-ktable)

Makes a CljKTable object.

Makes a CljKTable object.
sourceraw docstring

clj-kgroupedstreamclj

(clj-kgroupedstream kgroupedstream)

Makes a CljKGroupedStream object.

Makes a CljKGroupedStream object.
sourceraw docstring

clj-kgroupedtableclj

(clj-kgroupedtable kgroupedtable)

Makes a CljKGroupedTable object.

Makes a CljKGroupedTable object.
sourceraw docstring

clj-kstreamclj

(clj-kstream kstream)

Makes a CljKStream object.

Makes a CljKStream object.
sourceraw docstring

clj-ktableclj

(clj-ktable ktable)

Makes a CljKTable object.

Makes a CljKTable object.
sourceraw docstring

clj-session-windowed-kstreamclj

(clj-session-windowed-kstream windowed-kstream)

Makes a CljSessionWindowedKStream object.

Makes a CljSessionWindowedKStream object.
sourceraw docstring

clj-time-windowed-kstreamclj

(clj-time-windowed-kstream windowed-kstream)

Makes a CljTimeWindowedKStream object.

Makes a CljTimeWindowedKStream object.
sourceraw docstring

fn->topic-name-extractorclj

(fn->topic-name-extractor f)
source

header->cljclj

(header->clj header)
source

headers->cljclj

(headers->clj headers)
source

record-context->cljclj

(record-context->clj rc)
source

streams-builderclj

(streams-builder)

Makes a streams builder.

Makes a streams builder.
sourceraw docstring

suppress-config->suppressedclj

(suppress-config->suppressed {:keys [max-records max-bytes
                                     until-time-limit-ms]})
source

topic->consumedclj

(topic->consumed {:keys [key-serde value-serde]})
source

topic->materializedclj

(topic->materialized {:keys [topic-name key-serde value-serde]})
source

topic->producedclj

(topic->produced {:keys [key-serde value-serde partition-fn]})
source

topic->serializedclj

(topic->serialized {:keys [key-serde value-serde]})
source

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

× close