franzy.clients.cluster — ymilky/franzy 0.0.2-SNAPSHOT

Helpers and useful functions for working with Cluster metadata.

available-partitions clj

(available-partitions cluster topic)

Retrieve a collection of available partitions for a topic in a cluster.

bootstrap-cluster clj

(bootstrap-cluster addresses)

Bootstraps a cluster from a collection of InetAddresses.

bootstrap-cluster-hosts clj

(bootstrap-cluster-hosts host-map-coll)

Bootstraps a cluster from a collection of maps of host names and ports for InetAddresses.

ex: (bootstrap-cluster-hosts [{:host-name "localhost" :port 9092}])

empty-cluster clj

(empty-cluster)

leader-for clj

(leader-for cluster {:keys [topic partition]})

(leader-for cluster topic partition)

Retrives the partition leader for a given topic partition.

make-cluster clj

(make-cluster)

(make-cluster nodes partition-info)

(make-cluster nodes partition-info unauthorized-topics)

Creates a cluster from a given collection of nodes and partition info and an optional set of unauthorized topics.

If no parameters are provided, an empty cluster is created.

mock-cluster clj

(mock-cluster node-count topic-partitions unauthorized-topics)

Creates a mock cluster for testing, dev, and as dummy data for Kafka functions requiring clusters such as partitioners.

mock-nodes clj

(mock-nodes node-count)

Creates a mock number of nodes based on the provided node count.

node-by-id clj

(node-by-id cluster node-id)

Retrieves a node by its node id.

nodes clj

(nodes cluster)

Retrieves a collection of nodes in the cluster.

partition-count clj

(partition-count cluster topic)

Retrives the partition count for a given topic.

partition-info-for-topic clj

(partition-info-for-topic cluster {:keys [topic partition]})

(partition-info-for-topic cluster topic partition)

Retrieves the partition info for a given topic partition.

partitions-for-node clj

(partitions-for-node cluster node-id)

Retrieves a collection of partitions with a leader matching the given node id.

partitions-for-topic clj

(partitions-for-topic cluster topic)

Retrieves a collection of partitions for a given topic.

topics clj

(topics cluster)

Retrieves a collection of topics in this cluster.