(create-producer-record topic k v registry)(make-producer config)(make-producer-config config)(producer config)(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!! 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!! component topic k v async?)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |