kinsky.admin
Wrapper around Kafka's AdminClient
Wrapper around Kafka's `AdminClient`
AdminClientDrivercljprotocol
Driver protocol for admin clients
Driver protocol for admin clients
close!clj
(close! this)(close! this timeout)Close this driver
Close this driver
create-topicclj
(create-topic this topic-name topic-options)list-topicsclj
(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.
clientclj
(client config)Create an AdminClient from a configuration map.
Create an AdminClient from a configuration map.
kafka-future->wrapperclj
(kafka-future->wrapper kafka-future)(kafka-future->wrapper kafka-future map-result)Return a wrapper around a KafkaFuture. When mapper is present, the
function is applied to the result before being returned or pushed to a
channel. The wrapper also implements the IDeref interface for
easy synchronous consumption of the result.
Return a wrapper around a `KafkaFuture`. When `mapper` is present, the function is applied to the result before being returned or pushed to a channel. The wrapper also implements the `IDeref` interface for easy synchronous consumption of the result.
KafkaFutureWrappercljprotocol
Small wrapper for KafkaFuture instances.
Small wrapper for `KafkaFuture` instances.
to-chanclj
(to-chan this)(to-chan this channel)Returns a core.async channel to which the result is pushed. When
channel is present we use this channel to push data to.
Returns a `core.async` channel to which the result is pushed. When `channel` is present we use this channel to push data to.
topic-listing->dataclj
(topic-listing->data listing)Convert a TopicListing instance to a data map.
Convert a `TopicListing` instance to a data map.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close