@Override
        public void run() {
            try {
                update();
            } catch (Exception e) {
                WorkerUtils.abort(log, "ConsumeStatusUpdater", e, doneFuture);
            }
        }
Runnable class that updates the status of a single consumer
trogdor/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java