mx.interware.arp.io.kafka — mx.interware/caudal 0.7.1

consumer-parameters clj

create-consumer clj

(create-consumer parameters)

create-producer clj

(create-producer parameters)

kafka-send clj

(kafka-send topic-name parameters & children)

map-to-properties clj

(map-to-properties m)

producer-parameters clj

send-event clj

(send-event producer topic-name event)

start-processing clj

(start-processing channel sink)

subscribe clj

(subscribe consumer topic-name)