API namespace for the library
API namespace for the library
(consumer nodes group-id topics)(consumer nodes group-id topics {:as conf})Returns a manifold source of kafka consumer.
nodes: bootstrap servers url, e.g localhost:9092group-id: consumer group id.topics: a sequence of topics to listen on. e.g. `["test"]conf: an optional config map.
other conf optionsReturns 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)
(ignore strm)ignore a stream strm's output, return strm itself.
ignore a stream `strm`'s output, return `strm` itself.
(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 config conf.
other conf optionsReturns 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-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 to sinkreturns 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-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 from srcreturns 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 builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |