CanTestBrokerAdmin returns whether we can test the broker-only admin client.

CanTestBrokerAdminSecurity returns whether we can test the broker-only admin client security features.

Confirm shows the argument prompt to the user and returns a boolean based on whether or not the user confirms that it's ok to continue.

CopyInts copies a slice of ints.

InTerminal determines whether we're running in a terminal or not.

PrettyDuration returns a human-formatted duration string given an golang duration value.

PrettyRate returns a human-formatted rate from a count and a duration.

RandomString returns a random string with the argument length.

RetryUntil is a helper that will re-run the argument function multiple times (up to a duration limit) until it no longer produces an error.

SameElements determines whether two int slices have the same elements (in any order).

shows progress of a config repeatedly during an interval.

ShuffledKeys returns a shuffled version of the keys in the argument map.

SortedKeys returns the keys of the argument, sorted by value.

SortedKeysByValue returns the keys in a map, sorted by the map values.

Convert any struct to json string.

TestKafkaAddr returns a kafka bootstrap address for unit testing purposes.

TestZKAddr returns a zookeeper address for unit testing purposes.

TruncateStringMiddle truncates a string by replacing characters in the middle with "..." if needed.

TruncateStringSuffix truncates a string by replacing the trailing characters with "..." if needed.

Rebalance context struct.

Rebalance overall progress Config.

Rebalance Topic Round progress Config.

Rebalance topic progress Config.

KeySorter is a type for a function that sorts integer keys based on their values in a map.