simple-kafka.client — simple-kafka-client 0.2.3-a

deserialize clj

(deserialize data)

Deserialize bytes data as JSON, when failure, it will log as error and return nil

make-producer clj

(make-producer bootstrap-servers)

make-producer-memoize clj

send-record clj

(send-record producer topic-name k v)

serialize clj

(serialize obj)

start-job clj

(start-job bootstrap-servers
           group-id
           from-topic
           to-topic
           error-topic
           process-fn
           ex-fn
           opts)