Liking cljdoc? Tell your friends :D
Clojure only.

kafka-metamorphosis.java.kafka-streams-wrapper

Java-facing wrapper around kafka-metamorphosis.streams.

Emits io.github.caioclavico.kafkametamorphosis.KafkaStreamsWrapper.

Java-facing wrapper around kafka-metamorphosis.streams.

Emits io.github.caioclavico.kafkametamorphosis.KafkaStreamsWrapper.
raw docstring

ksw-branchclj

(ksw-branch this stream preds)
source

ksw-cleanupclj

(ksw-cleanup this)
source

ksw-closeclj

(ksw-close this)
source

ksw-createBuilderclj

(ksw-createBuilder this)
source

ksw-createKafkaStreamsclj

(ksw-createKafkaStreams this config)
source

ksw-filterclj

(ksw-filter this stream pred)
source

ksw-initclj

(ksw-init)
(ksw-init arg)
source

ksw-mapValuesclj

(ksw-mapValues this stream fn)
source

ksw-startclj

(ksw-start this)
source

ksw-stateclj

(ksw-state this)
source

ksw-streamclj

(ksw-stream this topics)
source

ksw-toclj

(ksw-to this stream topic)
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close