franzy.common.broker.parsers — clj-kafka.franzy/common 2.0.7

Helpers for parsing connection strings in Kafka.

connection-string->uris clj

(connection-string->uris connection-string)

Returns a collection of URIs from a connection connection string.

fragment->uri clj

(fragment->uri host-and-port)

Extracts a connection string fragment as a URI.

Useful for further parsing/usage with other APIs.

parse-host clj

(parse-host host-and-port)

Parses just the host from a host/port fragment in a connection string and returns it as a number.

parse-host-and-port clj

(parse-host-and-port host-and-port)

Parses a host/port fragment, and extracts them as a map.

parse-port clj

(parse-port host-and-port)

Parses just the port from a host/port fragment in a connection string and returns it as a number.

parse-ports clj

(parse-ports connection-string)

Returns a set of the ports used by a connection string.

Note that the ports may be open on different hosts, so this is more useful in scenarios such as testing on localhost or where a FQDN is used or in bridged configurations such as those used commonly by containers such as docker.

Useful for checking what ports are open in a cluster.

parse-server-hosts clj

(parse-server-hosts connection-string)

Returns a set of just the hosts from a connection string.

Useful for seeing what hosts are active in a cluster.

parse-server-list clj

(parse-server-list connection-string)

Parses the servers and ports in a connection string and returns a sequence of server/port maps.

Useful for logging and getting an overview of resource usage.

parse-servers clj

(parse-servers connection-string)

Returns a vector of server connection strings from a connection string.