jackdaw.streams.interop — com.github.parkside-securities/jackdaw 0.8.1-rc7

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
                                     name]})

topic->consumed clj

(topic->consumed {: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]})

topic->serialized clj

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