开发者社区 问答 正文

DTS出现Cluster changed from *** to ***, consumer ...

已解决

DTS出现Cluster changed from *** to ***, consumer require restart.的报错提示该如何解决

展开
收起
提个问题 2024-06-01 12:06:57 57 分享 版权
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答

    DTS出现Cluster changed from *** to ***, consumer require restart.的报错可能是因为DTS用于读取增量数据的模块DStore发生切换,导致Flink客户端的消费位点丢失,您无需重启客户端,仅需查询客户端的消费位点,并在DtsExample.java和DtsTableISelectTCaseTest.java文件中重新传入消费位点checkpointdts.checkpoint,即可重新消费订阅数据。

    2024-06-01 12:06:58
    赞同 展开评论
问答标签:
问答地址:
关联地址: