jackdaw.streams.interop — fundingcircle/jackdaw 0.9.12

Clojure wrapper to kafka streams.

clj-global-ktable clj

(clj-global-ktable global-ktable)

Makes a CljKTable object.

clj-kgroupedstream clj

(clj-kgroupedstream kgroupedstream)

Makes a CljKGroupedStream object.

clj-kgroupedtable clj

(clj-kgroupedtable kgroupedtable)

Makes a CljKGroupedTable object.

clj-kstream clj

(clj-kstream kstream)

Makes a CljKStream object.

clj-ktable clj

(clj-ktable ktable)

Makes a CljKTable object.

clj-session-windowed-kstream clj

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

Makes a CljSessionWindowedKStream object.

clj-time-windowed-kstream clj

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

Makes a CljTimeWindowedKStream object.

streams-builder clj

(streams-builder)

Makes a streams builder.

suppress-config->suppressed clj

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

topic->consumed clj

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

topic->grouped clj

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

topic->materialized clj

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

topic->produced clj

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