common-clj.component.kafka.consumer — net.clojars.macielti/common-clj 26.53.53

consumed-messages clj

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

handler-by-topic clj

(handler-by-topic topic topic-consumers)

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

kafka-client-starter clj

kafka-consumer! clj

map->Consumer clj

(map->Consumer m48629)

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.)

new-consumer clj

(new-consumer topic-consumers)

new-mock-consumer clj

(new-mock-consumer topic-consumers)

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]

strict-map->Consumer clj

(strict-map->Consumer m48630 & [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->

subscriber clj