(->topic-partition-array tp-seq)Converts a sequence of topic-partition maps to a Collection of TopicPartition objects. Despite the name, returns a java.util.List for compatibility with Kafka's Consumer API.
Converts a sequence of topic-partition maps to a Collection of TopicPartition objects. Despite the name, returns a java.util.List for compatibility with Kafka's Consumer API.
(client-metrics client)Extracts metrics from a Kafka client (producer or consumer) and returns a sequence of maps with :group, :name, :description, :tags, and :value keys.
Extracts metrics from a Kafka client (producer or consumer) and returns a sequence of maps with :group, :name, :description, :tags, and :value keys.
(client-partitions-for client topic)Returns partition info for a topic from a Kafka client (producer or consumer) as a vector of maps.
Returns partition info for a topic from a Kafka client (producer or consumer) as a vector of maps.
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 |