Wrapper around Kafka's AdminClient
Wrapper around Kafka's `AdminClient`
Driver protocol for admin clients
Driver protocol for admin clients
(close! this)(close! this timeout)Close this driver
Close this driver
(create-topic this topic-name topic-options)(list-topics this list-internal?)List all available topics. When list-internal? is true the list of
internal topics (__consumer_offsets) is also returned.
List all available topics. When `list-internal?` is `true` the list of internal topics (`__consumer_offsets`) is also returned.
(client config)Create an AdminClient from a configuration map.
Create an AdminClient from a configuration map.
(kafka-future-wrapper kafka-future result-transform)Return a promise representing the result of a KafkaFuture
transformed by the result-transform function.
Return a promise representing the result of a `KafkaFuture` transformed by the `result-transform` function.
(topic-listing->data listing)Convert a TopicListing instance to a data map.
Convert a `TopicListing` instance to a data map.
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 |