jackdaw.streams.configured

Clojure wrapper to kafka streams.

(configured-global-ktable config global-ktable)

Makes a ConfiguredKTable object.

(configured-kgroupedstream config kgroupedstream)

Makes a ConfiguredKGroupedStream object.

(configured-kgroupedtable config kgroupedtable)

Makes a ConfiguredKGroupedTable object.

(configured-kstream config kstream)

Makes a ConfiguredStream object.

(configured-ktable config ktable)

Makes a ConfiguredKTable object.

(configured-session-windowed-kstream config kgroupedstream)

Makes a ConfiguredKGroupedStream object.

(configured-time-windowed-kstream config kgroupedstream)

Makes a ConfiguredKGroupedStream object.

(streams-builder config streams-builder)

Makes a topology builder.

Generated by Codox