Future<Void> transitionToStopping() {
            state = State.STOPPING;
            if (timeoutFuture != null) {
                timeoutFuture.cancel(false);
                timeoutFuture = null;
            }
            return workerCleanupExecutor.submit(new HaltWorker(this));
        }
Whether we should destroy the records of this worker once it stops.
trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java