dais.kafka.client — infihis/dais 0.3.1

<!!send clj macro

(<!!send & args)

<!send clj macro

(<!send & args)

async-consumer clj

(async-consumer opts topics output-chan)

close-producer clj

(close-producer p)

consumer clj

(consumer opts)

producer clj

(producer opts)

send! clj

(send! p {:keys [topic partition timestamp key value headers]})

send-raw! clj

(send-raw! p record)

(send-raw! p {:keys [topic partition timestamp key value headers]} callback)

stop-consumer! clj

(stop-consumer! c)