public TaskController newController(String id) {
        return topology -> new TreeSet<>(clientNodes);
    }
The specification for a task which connects and disconnects many times a
second to stress the broker.
trogdor/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressSpec.java