Project

Topics

Namespaces

Public Vars

jackdaw.streams.interop

Clojure wrapper to kafka streams.

clj-global-ktable

(clj-global-ktable global-ktable)
Makes a CljKTable object.
view source

clj-kgroupedstream

(clj-kgroupedstream kgroupedstream)
Makes a CljKGroupedStream object.
view source

clj-kgroupedtable

(clj-kgroupedtable kgroupedtable)
Makes a CljKGroupedTable object.
view source

clj-kstream

(clj-kstream kstream)
Makes a CljKStream object.
view source

clj-ktable

(clj-ktable ktable)
Makes a CljKTable object.
view source

clj-session-windowed-kstream

(clj-session-windowed-kstream windowed-kstream)
Makes a CljSessionWindowedKStream object.
view source

clj-time-windowed-kstream

(clj-time-windowed-kstream windowed-kstream)
Makes a CljTimeWindowedKStream object.
view source

streams-builder

(streams-builder)
Makes a streams builder.
view source

topic->consumed

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