code: def xgroup_create(self, stream, group_name, latest_id='$', mkstream=False):
          
          args = [b'CREATE', stream, group_name, latest_id]
          if mkstream:
              args.append(b'MKSTREAM')
          fut = self.execute(b'XGROUP', *args)
          return wait_ok(fut)
docs: Create a consumer group