public AgentClient agentClient(String nodeName) {
        Agent agent = agents.get(nodeName);
        if (agent == null) {
            throw new RuntimeException("No agent configured on node " + nodeName);
        }
        return new AgentClient.Builder().
            maxTries(10).
            target("localhost", agent.port()).
            build();
    }
Mimic a restart of a Trogdor agent, essentially cleaning out all of its active workers
trogdor/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java