遇到过这种bug吗https://github.com/ververica/flink-cdc-co

根据您提供的链接，该问题是在使用Flink CDC Connectors时遇到的特定错误，具体表现为在同步PostgreSQL数据库时，如果表的REPLICA IDENTITY设置不是FULL，则可能导致更新或删除操作的消息中“before”字段为null，进而引发异常。此问题的具体错误信息与知识库中的报错描述相匹配。

问题描述

用户在使用Flink CDC Connectors同步PostgreSQL数据库时，遇到错误提示：“The "before" field of UPDATE/DELETE message is null”。

原因分析

• 原因：PostgreSQL表的REPLICA IDENTITY未设置为FULL级别，这导致Debezium无法捕获到更新或删除操作前的行数据，从而在消息中缺失“before”图像。

解决步骤

1. 修改表的REPLICA IDENTITY设置：

   • 需要在PostgreSQL数据库中执行SQL命令，将涉及的表的REPLICA IDENTITY设置为FULL。命令示例为：

     ALTER TABLE your_schema.your_table REPLICA IDENTITY FULL;
     

   • 其中，your_schema和your_table需要替换为实际的数据库模式和表名。

2. 重启或重新部署Flink作业：

   • 在完成上述设置后，确保重启或重新部署您的Flink CDC同步任务，以便新的设置生效。

注意事项

• 备份数据：在执行任何DDL更改之前，请确保对相关数据库和表进行备份，以防配置更改导致意外的数据丢失。
• 验证更改：更改REPLICA IDENTITY设置后，通过监控或小范围测试验证Flink CDC作业是否正常运行，确认更新和删除事件能够正确捕获并处理。

通过以上步骤，可以解决因REPLICA IDENTITY设置不当导致的“before”字段为空的问题。如果问题仍然存在，建议查阅Flink CDC Connectors的官方文档或直接在GitHub项目中查找相似问题的解决方案，甚至考虑提交一个新的issue来获取维护者的帮助。