def METHOD_NAME(self):
    """
    :return: The latest offset value in the format expected by the ``since`` param
             of ``iter_changes``:
               * string change ID for Cloudant and CouchDB
               * int change ID for single kafka topic
               * or a dict if multiple kafka topics are used
    """