jackdaw.streams.interop — net.clojars.savya/jackdaw 1.3.3

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

Builds a Kafka Streams Suppressed from a suppression config, choosing the buffer bound from :max-records, :max-bytes, or :until-time-limit-ms.

topic->consumed clj

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

Builds a Kafka Streams Consumed from a topic config's :key-serde and :value-serde.

topic->grouped clj

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

Builds a Kafka Streams Grouped from a topic config's :key-serde and :value-serde.

topic->materialized clj

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

Builds a Kafka Streams Materialized store named by :topic-name, applying the topic config's key/value serdes when present.

topic->produced clj

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

Builds a Kafka Streams Produced from a topic config's serdes, attaching a custom stream partitioner when :partition-fn is present.

topic->repartitioned clj

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

Builds a Kafka Streams Repartitioned from a topic config's serdes, applying :topic-name and a :partition-fn partitioner when present.