code: def xclaim(self, stream, group_name, consumer_name, min_idle_time,
                 id, *ids):
          
          fut = self.execute(
              b'XCLAIM', stream, group_name, consumer_name, min_idle_time,
              id, *ids
          )
          return wait_convert(fut, parse_messages)
docs: Claim a message for a given consumer