ketu.async.sink

Liking cljdoc? Tell your friends :D

Clojure only.

default-opts
default-producer-supplier
done-chan
finalize-apache-config
logger
sink
stop!

default-opts^clj

(default-opts)

source

default-producer-supplier^clj

(default-producer-supplier opts)

source

done-chan^clj

(done-chan state)

source

finalize-apache-config^clj

(finalize-apache-config opts)

Returns opts with final :ketu.apache.producer/config entry

Returns opts with final :ketu.apache.producer/config entry

source raw docstring

logger^clj

source

sink^clj

(sink in-chan opts)

Sends ProducerRecord's from in-chan to kafka. Closes the producer by default when in-chan is exhausted or when calling stop! If :ketu.sink/close-producer? is set to false the user will have to close the producer manually.

Sends ProducerRecord's from in-chan to kafka.
Closes the producer by default when in-chan is exhausted or when calling `stop!`
If `:ketu.sink/close-producer?` is set to `false` the user will have to close
the producer manually.

source raw docstring

stop!^clj

(stop! state)

Sends everything in the input channel to kafka and closes the producer. Input channel should be closed before calling this function. It shouldn't be necessary to call this function since by default the sink closes itself automatically when the input channel is closed.

Sends everything in the input channel to kafka and closes the producer.
Input channel should be closed before calling this function.
It shouldn't be necessary to call this function since by default the sink closes
itself automatically when the input channel is closed.

source raw docstring