private void position(FetchPosition position) {
            if (!hasValidPosition())
                throw new IllegalStateException("Cannot set a new position without a valid current position");
            this.position = position;
        }
Clear the awaiting validation state and enter fetching.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java