public void changeState(State newState, long now) {
        lastState.getAndUpdate(oldState -> oldState.newState(newState, now));
    }
Change the current state.

@param newState the current state; may not be null
@param now      the current time in milliseconds
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java