public StringBuilder adminSetBalanceGroupConsumeFromMax(HttpServletRequest req,
            StringBuilder sBuffer,
            ProcessResult result) {
        // check and get operation info
        if (!WebParameterUtils.getAUDBaseInfo(req, false, null, sBuffer, result)) {
            WebParameterUtils.buildFailResult(sBuffer, result.getErrMsg());
            return sBuffer;
        }
        BaseEntity opEntity = (BaseEntity) result.getRetData();
        // get group list
        if (!WebParameterUtils.getStringParamValue(req,
                WebFieldDef.COMPSGROUPNAME, true, null, sBuffer, result)) {
            WebParameterUtils.buildFailResult(sBuffer, result.getErrMsg());
            return sBuffer;
        }
        final Set<String> groupNameSet = (Set<String>) result.getRetData();
        // process offset setting
        ConsumerInfoHolder consumerHolder = master.getConsumerHolder();
        List<String> clientGroups = consumerHolder.getAllClientBalanceGroups();
        Set<String> filtedGroupSet = new TreeSet<>();
        for (String groupName : groupNameSet) {
            if (clientGroups.contains(groupName)) {
                filtedGroupSet.add(groupName);
            }
        }
        if (filtedGroupSet.isEmpty()) {
            WebParameterUtils.buildFailResult(sBuffer,
                    "all consumer groups are not client balance groups");
        } else {
            ConsumeGroupInfo groupInfo;
            for (String groupName : filtedGroupSet) {
                groupInfo = consumerHolder.getConsumeGroupInfo(groupName);
                if (groupInfo == null) {
                    continue;
                }
                groupInfo.updCsmFromMaxCtrlId();
            }
            logger.info(sBuffer.append("[Admin reset] ").append(opEntity.getModifyUser())
                    .append(" set client-balance group consume from max offset, group set = ")
                    .append(filtedGroupSet.toString()).toString());
            sBuffer.delete(0, sBuffer.length());
            WebParameterUtils.buildSuccessResult(sBuffer);
        }
        return sBuffer;
    }
Set online client-balance group consume from max offset

@param req     the request object
@param sBuffer  string buffer
@param result   the result object
@return  the return result
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebAdminGroupCtrlHandler.java