持久化流表的数据会定期清理,因此如果要从磁盘上现存的第一条开始订阅,需要通过 getPersistenceMeta 获取 diskOffset 然后从这个 offset 开始订阅;或者订阅流表的时候,设置 persistOffset 参数,持久化保存最新一条已经处理的订阅数据的偏移量。持久化保存的偏移量用于重订阅,可通过 getTopicProcessedOffset 函数获取。
持久化流表的数据会定期清理,因此如果要从磁盘上现存的第一条开始订阅,需要通过 getPersistenceMeta 获取 diskOffset 然后从这个 offset 开始订阅;或者订阅流表的时候,设置 persistOffset 参数,持久化保存最新一条已经处理的订阅数据的偏移量。持久化保存的偏移量用于重订阅,可通过 getTopicProcessedOffset 函数获取。