clj-kafka.core

->KafkaMessage

(->KafkaMessage topic offset partition key value)

Positional factory function for class clj_kafka.core.KafkaMessage.

view source

as-properties

(as-properties m)
view source

map->KafkaMessage

(map->KafkaMessage m__5818__auto__)

Factory function for class clj_kafka.core.KafkaMessage, taking a map of keywords to field values.

view source

ToClojure

protocol

members

to-clojure

(to-clojure x)

Converts type to Clojure structure

view source

with-resource

macro

(with-resource binding close-fn & body)
view source