public InlongGroupOperator getInstance(String mqType) {
        Optional<InlongGroupOperator> instance = groupOperatorList.stream()
                .filter(inst -> inst.accept(mqType))
                .findFirst();
        if (!instance.isPresent()) {
            throw new BusinessException(ErrorCodeEnum.MQ_TYPE_NOT_SUPPORTED,
                    String.format(ErrorCodeEnum.MQ_TYPE_NOT_SUPPORTED.getMessage(), mqType));
        }
        return instance.get();
    }
Get a group operator instance via the given mqType
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupOperatorFactory.java