grete.core — tolitius/grete 0.1.8003

close clj

(close producer)

consume clj

(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'

consumer clj

(consumer conf)

consumer-records->maps clj

(consumer-records->maps cs)

offsets clj

(offsets c)

poll clj

(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.

producer clj

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

reset-offsets clj

(reset-offsets c topic pnum)

run-consumers clj

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

send! clj

(send! producer topic msg)

(send! producer topic key msg)

dummy gregor send wrap to:

1. give it a '!'
2. avoid requiring another ns to 'send'

stop-consumers clj

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

to-prop clj

(to-prop k)

to-props clj

(to-props conf)

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