Liking cljdoc? Tell your friends :D

common-clj.component.kafka.consumer


consumed-messagesclj

(consumed-messages {:keys [consumed-messages]})
source

handler-by-topicclj

(handler-by-topic topic topic-consumers)

Inputs: [topic :- s/Keyword topic-consumers]

Inputs: [topic :- s/Keyword topic-consumers]
sourceraw docstring

kafka-client-starterclj

source

kafka-consumer!clj

source

map->Consumerclj

(map->Consumer m48634)

Factory function for class Consumer, taking a map of keywords to field values, but not much slower than ->x like the clojure.core version. (performance is fixed in Clojure 1.7, so this should eventually be removed.)

Factory function for class Consumer, taking a map of keywords to field values, but not much
slower than ->x like the clojure.core version.
(performance is fixed in Clojure 1.7, so this should eventually be removed.)
sourceraw docstring

new-consumerclj

(new-consumer topic-consumers)
source

new-mock-consumerclj

(new-mock-consumer topic-consumers)
source

replay-dead-letter!clj

(replay-dead-letter! {:keys [topic data]} service-name exception-info producer)

Inputs: [{:keys [topic data]} :- component.kafka.models/KafkaMessage service-name exception-info :- s/Str producer]

Inputs: [{:keys [topic data]} :- component.kafka.models/KafkaMessage service-name exception-info :- s/Str producer]
sourceraw docstring

strict-map->Consumerclj

(strict-map->Consumer m48635 & [drop-extra-keys?__7745__auto__])

Factory function for class Consumer, taking a map of keywords to field values. All keys are required, and no extra keys are allowed. Even faster than map->

Factory function for class Consumer, taking a map of keywords to field values.  All keys are required, and no extra keys are allowed.  Even faster than map->
sourceraw docstring

subscriberclj

source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close