@Override
        public void onPause(String connector) {
            state = AbstractStatus.State.PAUSED;
            synchronized (this) {
                if (!cancelled) {
                    delegate.onPause(connector);
                }
            }
        }
Use {@link AbstractStatus.State} since it has all of the states we want,
unlike {@link WorkerConnector.State}.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java