返回可用的最新偏移量。
此信息用于报告流式处理查询状态中的最新偏移量。 如果没有要处理的数据,或者源不支持此方法,则源可以返回 None 。
Syntax
reportLatestOffset()
退货
dict 或 None
一个听写或递归听写,其键和值是基元类型,包括整数、字符串和布尔值。 如果 None 源不支持报告最新偏移量,则返回。
示例
def reportLatestOffset(self):
return {"partition-1": {"index": 100}, "partition-2": {"index": 200}}