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

consumed-messages clj deprecated

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

handler-by-topic clj deprecated

(handler-by-topic topic topic-consumers)

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

kafka-client-starter clj deprecated

kafka-consumer! clj deprecated

map->Consumer clj

(map->Consumer m34976)

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 deprecated

(new-consumer topic-consumers)

new-mock-consumer clj deprecated

(new-mock-consumer topic-consumers)

replay-dead-letter! clj deprecated

(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 m34977 & [drop-extra-keys?__7798__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 deprecated