Liking cljdoc? Tell your friends :D

grete.core


closeclj

(close {:keys [producer]})
source

consumeclj

(consume consumer process running? ms n)

the 'process' function will take 'org.apache.kafka.clients.consumer.ConsumerRecords' which can be turns to a seq of maps with 'consumer-records->maps'

the 'process' function will take 'org.apache.kafka.clients.consumer.ConsumerRecords'
which can be turns to a seq of maps with 'consumer-records->maps'
sourceraw docstring

consumerclj

(consumer conf)
source

consumer-records->mapsclj

(consumer-records->maps cs)
source

offsetsclj

(offsets c)
source

pollclj

(poll consumer)
(poll consumer timeout)

fetches sequetially from the last consumed offset return 'org.apache.kafka.clients.consumer.ConsumerRecords' currently available to the consumer (via a single poll) if a 'timeout' param is 0, returns immediately with any records that are available now.

fetches sequetially from the last consumed offset
return 'org.apache.kafka.clients.consumer.ConsumerRecords' currently available to the consumer (via a single poll)
if a 'timeout' param is 0, returns immediately with any records that are available now.
sourceraw docstring

producerclj

(producer topic {:keys [bootstrap-servers] :as conf})
source

reset-offsetsclj

(reset-offsets c topic pnum)
source

run-consumersclj

(run-consumers process {:keys [threads poll-ms] :as conf})
source

send!clj

(send! {:keys [producer topic]} msg)
(send! {:keys [producer topic]} key msg)
source

stop-consumersclj

(stop-consumers {:keys [pool running?]})
source

to-propclj

(to-prop k)
source

to-propsclj

(to-props conf)

ranames keys by converting them to strings and substituting dashes with periods only does top level keys

ranames keys by converting them to strings and substituting dashes with periods
only does top level keys
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close