Flink CDC中有没有遇到程序停了,pg插槽的状态还是激活，再重启程序说插槽被激活？

是可能会遇到这个情况的:

Flink CDC程序监听Postgres复制插槽状态时出现异常停止。

但Postgres端,该插槽状态并没有被正确地从'active'改为'standby'。

这样一来,下次启动CDC程序时,就会报错说该插槽还在'active'状态了。

这主要是因为:

Flink程序Crash后,没有机会将插槽状态从Postgres端正确切换为'standby'。

Postgres默认一段时间内,插槽保持'active'状态以保证数据不丢失。

为了解决这个问题,可以:

重启Postgres数据库,清理未使用的插槽

设置插槽的max_slot_age让它更快过期

Flink程序增加超时重试机制,多次尝试将插槽切换为'standby'

优化程序稳定性,减少意外Crash的 possibilities