Liking cljdoc? Tell your friends :D

kafkakit.component.producer


create-producer-record

(create-producer-record topic k v registry)

make-producer

(make-producer config)

make-producer-config

(make-producer-config config)

producer

(producer config)

Publisherprotocol

publish!!
(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.

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!!
(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.

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!!

(send!! component topic k v async?)

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close