订阅持久化流表报错 can't find the message with offset 0

根据该报错显示订阅offset不能写 0, 如果我要订阅磁盘上的第一条数据,应该如何指定 offset 呢,如果不能写 0 的话应该写多少呢?

请先 登录 后评论

1 个回答

Polly

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

请先 登录 后评论