private void triggerStop() {
        synchronized (this) {
            stopping = true;

            // wakeup any threads that are waiting for unpause
            this.notifyAll();
        }
    }
Initialize the task for execution.

@param taskConfig initial configuration
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java