@Override
        public void raiseError(Exception e) {
            log.error("{} Connector raised an error", WorkerConnector.this, e);
            onFailure(e);
            WorkerConnector.this.ctx.raiseError(e);
        }
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