public void requestEndOffset() {
            endOffsetRequested = true;
        }
Enable fetching and updating positions for the given partitions that were added to the
assignment, but waiting for the onPartitionsAssigned callback to complete. This is
expected to be used by the async consumer.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java