kinsky.admin
Wrapper around Kafka’s AdminClient
AdminClientDriver
protocol
Driver protocol for admin clients
members
close!
(close! this)(close! this timeout)Close this driver
create-topic
(create-topic this topic-name topic-options)list-topics
(list-topics this list-internal?)List all available topics. When list-internal? is true the list of internal topics (__consumer_offsets) is also returned.
kafka-future->wrapper
(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.
KafkaFutureWrapper
protocol
Small wrapper for KafkaFuture instances.
members
to-chan
(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.
topic-listing->data
(topic-listing->data listing)Convert a TopicListing instance to a data map.