reportLatestOffset

返回可用的最新偏移量。

此信息用于报告流式处理查询状态中的最新偏移量。 如果没有要处理的数据,或者源不支持此方法,则源可以返回 None

Syntax

reportLatestOffset()

退货

dictNone

一个听写或递归听写,其键和值是基元类型,包括整数、字符串和布尔值。 如果 None 源不支持报告最新偏移量,则返回。

示例

def reportLatestOffset(self):
    return {"partition-1": {"index": 100}, "partition-2": {"index": 200}}