StatusData update() {
            Histogram.Summary summary = histogram.summarize(StatusData.PERCENTILES);
            StatusData statusData = new StatusData(summary.numSamples(), summary.average(),
                summary.percentiles().get(0).value(),
                summary.percentiles().get(1).value(),
                summary.percentiles().get(2).value(),
                transactionsCommitted.get());
            status.update(JsonUtil.JSON_SERDE.valueToTree(statusData));
            return statusData;
        }
A subclass of Throttle which flushes the Producer right before the throttle injects a delay.
This avoids including throttling latency in latency measurements.
trogdor/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java