code: def create_consumer_group(self, project, logstore, consumer_group, timeout, in_order=False):
          
          request = CreateConsumerGroupRequest(project, logstore, ConsumerGroupEntity(consumer_group, timeout, in_order))
          consumer_group = request.consumer_group
          body_str = consumer_group.to_request_json()
  
          headers = {
              "x-log-bodyrawsize": '0',
              "Content-Type": "application/json"
          }
          params = {}
  
          project = request.get_project()
          resource = "/logstores/" + request.get_logstore() + "/consumergroups"
          (resp, header) = self._send("POST", project, body_str, resource, params, headers)
          return CreateConsumerGroupResponse(header, resp)
docs: create consumer group
  
          :type project: string
          :param project: project name
  
          :type logstore: string
          :param logstore: logstore name
  
          :type consumer_group: string
          :param consumer_group: consumer group name
  
          :type timeout: int
          :param timeout: time-out
  
          :type in_order: bool
          :param in_order: if consume in order, default is False
  
          :return: CreateConsumerGroupResponse