开发者社区> 问答> 正文

Flink读取Postgres CDC配置了debezium.slot.name任务停止后怎么...

已解决

Flink读取Postgres CDC配置了debezium.slot.name任务停止后怎么删除slot

展开
收起
提个问题 2024-06-10 19:10:49 109 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    Flink默认情况下如果配置了debezium.slot.name任务停止后默认不会删除slot,需要在数据库侧手动进行删除,如果需要再任务停止后自动删除slot 可以配置 debezium.slot.drop.on.stop = true 但是会导致无法从checkpoint恢复回来。详情参考文档
    2024-06-10 19:10:50
    赞同 展开评论 打赏
归属于问产品:
实时计算 Flink版
进入专区
问答排行榜
最热
最新

相关电子书

更多
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
基于 Flink CDC 打造 企业级实时数据集成方案 立即下载
李劲松|Flink Table Store 典型应用场景 立即下载