public void throttle(Node node, long durationMs) {
        connectionState(node.idString()).throttle(time.milliseconds() + durationMs);
    }
A mock network client for use testing code
clients/src/test/java/org/apache/kafka/clients/MockClient.java