TDengine设置subscribe参数restart=false仍从头消费如何解决

1. 核心代码逻辑问题 #

你提供的代码中while(true)是死循环，没有设置退出触发逻辑，sub.close(true)这行代码永远不会被执行。TDengine的订阅offset默认是在调用close(true)时才会持久化到本地，如果你是直接强制终止进程结束程序，最新的消费位点根本没有保存，重启后自然会从数据开头重新消费。
你可以添加终止信号监听逻辑，比如捕获SIGINT信号，在程序退出前主动调用sub.close(true)保证offset持久化。

2. 本地offset文件异常 #

TDengine Java连接器的订阅offset默认持久化在/tmp/taossubscribe目录下：

• 如果该目录被系统定期清理、目录权限不足无法写入，或者你更换了运行程序的机器，已保存的offset就会丢失，重启订阅就会从头消费
• 你可以在创建订阅时自定义offset存储路径，避免默认临时目录被清理导致的位点丢失问题

3. 连接器版本BUG #

2.0.x系列低于2.0.30版本、3.0.x系列低于3.0.2版本的TDengine JDBC连接器存在订阅offset持久化失效的已知问题，升级到对应分支的最新稳定版本即可解决。

4. 订阅配置冲突 #

• 确认你没有在程序的其他位置以restart=true的参数创建过同一个topic的订阅，一旦用restart=true创建过订阅，之前保存的offset会被重置，后续即使改回restart=false也会从头消费
• 3.x版本的TDengine订阅topic需要全局唯一，确认没有其他应用占用了同一个topic名重置了offset

内容的提问来源于stack exchange，提问作者Ray Shown