kinsky.admin — spootnik/kinsky 0.1.25

Wrapper around Kafka's AdminClient

AdminClientDriver clj protocol

Driver protocol for admin clients

close! clj

(close! this)

(close! this timeout)

Close this driver

create-topic clj

(create-topic this topic-name topic-options)

list-topics clj

(list-topics this list-internal?)

List all available topics. When list-internal? is true the list of internal topics (__consumer_offsets) is also returned.

client clj

(client config)

Create an AdminClient from a configuration map.

kafka-future-wrapper clj

(kafka-future-wrapper kafka-future result-transform)

Return a promise representing the result of a KafkaFuture transformed by the result-transform function.

topic-listing->data clj

(topic-listing->data listing)

Convert a TopicListing instance to a data map.