@ResponseBody
    @PostMapping("")
    public TubeMQResult groupMethodProxy(@RequestParam String method, @RequestBody String req) {
        switch (method) {
            case TubeConst.ADD:
                return batchAddGroup(gson.fromJson(req, BatchAddGroupAuthReq.class));
            case TubeConst.DELETE:
                return masterService.baseRequestMaster(gson.fromJson(req, DeleteGroupReq.class));
            case TubeConst.BATCH_DELETE:
                return masterService.baseRequestMaster(gson.fromJson(req, BatchDeleteGroupReq.class));
            case TubeConst.REBALANCE_CONSUMER_GROUP:
                return topicService.rebalanceGroup(gson.fromJson(req, RebalanceGroupReq.class));
            case TubeConst.REBALANCE_CONSUMER:
                return masterService.baseRequestMaster(gson.fromJson(req, RebalanceConsumerReq.class));
            case TubeConst.FILTER_CONDITION:
                return masterService.baseRequestMaster(gson.fromJson(req, FilterCondGroupReq.class));
            case TubeConst.FLOW_CONTROL:
                return masterService.baseRequestMaster(gson.fromJson(req, FlowControlGroupReq.class));
            case TubeConst.QUERY:
                return queryGroupExist(gson.fromJson(req, QueryConsumerGroupReq.class));
            default:
                return TubeMQResult.errorResult(TubeMQErrorConst.NO_SUCH_METHOD);
        }
    }
Consumer group related request operations

@param method method type
@param req incoming data
@return return request data
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/group/GroupController.java