kafkakit.component.producer — bridg/kafkakit 0.5.0

create-producer-record clj

(create-producer-record topic k v registry)

make-producer clj

(make-producer config)

make-producer-config clj

(make-producer-config config)

producer clj

(producer config)

Publisher clj protocol

publish!! clj

(publish!! component topic k v)

Publishes synchronously, blocking until the write is acknowledged. Params: component: The component. topic: Topic name for the event. Ex: "audiences" k: Kafka message key. v: Kafka message value.

publish-async!! clj

(publish-async!! component topic k v)

Publishes asynchronously, non-blocking on write. Returns Future of RecordMetadata that can optionally be polled for (blocks if done). Params: component: The component. topic: Topic name for the event. Ex: "audiences" k: Kafka message key. v: Kafka message value.

send!! clj

(send!! component topic k v async?)