Liking cljdoc? Tell your friends :D
Clojure only.
robertluo.waterfall
API namespace for the library
API namespace for the library
consumerclj
(consumer nodes group-id topics)(consumer nodes group-id topics {:as conf})Returns a manifold source of kafka consumer.
nodes: bootstrap servers url, e.glocalhost:9092group-id: consumer group id.topics: a sequence of topics to listen on. e.g. `["test"]conf: an optional config map. other conf options
Returns a manifold source of kafka consumer. - `nodes`: bootstrap servers url, e.g `localhost:9092` - `group-id`: consumer group id. - `topics`: a sequence of topics to listen on. e.g. `["test"] - `conf`: an optional config map. [other conf options](https://kafka.apache.org/33/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html)
ignoreclj
(ignore strm)ignore a stream strm's output, return strm itself.
ignore a stream `strm`'s output, return `strm` itself.
producerclj
(producer nodes)(producer nodes {:as conf})Returns a manifold stream of kafka producer. Can accept map value put onto it,
and output the putting result. If your do not care about the output, wrap it with ignore.
nodes: bootstrap servers urls, e.g.localhost:9092conf: optional configconf. other conf options
Returns a manifold stream of kafka producer. Can accept map value put onto it, and output the putting result. If your do not care about the output, wrap it with `ignore`. - `nodes`: bootstrap servers urls, e.g. `localhost:9092` - `conf`: optional config `conf`. [other conf options](https://kafka.apache.org/33/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html)
xform-sinkclj
(xform-sink sink xform)returns a sink stream on sink stream, all event put on it will be transformed using
transducer xform before pass to sink.
sink: sink stream.xform: a transducer transforms events, then put tosink
returns a sink stream on `sink` stream, all event put on it will be transformed using transducer `xform` before pass to `sink`. - `sink`: sink stream. - `xform`: a transducer transforms events, then put to `sink`
xform-sourceclj
(xform-source src xform)returns a source stream on src transforming event from src using transducer xform.
will close source if this is drained.
src: source stream.xform: a transducer for transforming data fromsrc
returns a source stream on `src` transforming event from `src` using transducer `xform`. will close source if this is drained. - `src`: source stream. - `xform`: a transducer for transforming data from `src`
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close