class SubscriptionState {

    public synchronized void position(TopicPartition tp, FetchPosition position) {
        assignedState(tp).position(position);
    }

    public  SubscriptionState(LogContext logContext, OffsetResetStrategy defaultResetStrategy);

}