Liking cljdoc? Tell your friends :D
Clojure only.
kafka-clj.response
error?clj
(error? error-code)in->kafkarespseqclj
(in->kafkarespseq in)Return kafka responses with format e.g '(kafka_clj.response.ProduceResponse{:correlation-id 1, :topic test1, :partition 0, :error-code 0, :offset 28147497671196680} ..)
Return kafka responses with format e.g
'(kafka_clj.response.ProduceResponse{:correlation-id 1, :topic test1, :partition 0, :error-code 0, :offset 28147497671196680} ..)
inpartition->kafkarespseqclj
(inpartition->kafkarespseq in corrid topic-name)intopic->kafkarespseqclj
(intopic->kafkarespseq in corrid)lazy-array-readclj
(lazy-array-read len f)read-intclj
(read-int in)read-longclj
(read-long in)read-metadata-responseclj
(read-metadata-response in)read-short-string2clj
(read-short-string2 in)read-short2clj
(read-short2 in)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close