jackdaw.streams.interop — dakra/jackdaw 0.7.7

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.

fn->topic-name-extractor clj

(fn->topic-name-extractor f)

header->clj clj

(header->clj header)

headers->clj clj

(headers->clj headers)

record-context->clj clj

(record-context->clj rc)

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