common-clj.components.producer.kafka-producer — lucasmafra/common-clj 0.58.0

build-record clj

(build-record kafka-topic message)

Inputs: [kafka-topic :- s/Str message]

new-kafka-client clj

(new-kafka-client props)

new-producer clj

(new-producer producer-topics)

Inputs: [producer-topics :- schemata.producer/ProducerTopics]

producer-props clj

(producer-props config)

strict-map->KafkaProducerImpl clj

(strict-map->KafkaProducerImpl m27496 & [drop-extra-keys?__2573__auto__])

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