Flink CDC这个是在2.4.1解决的吗？

这个问题已经在 2.4.1 版本中修复了。

在 2.4.1 版本中，我们修复了一个导致 PostgreSQL CDC 连接器在某些情况下无法正确处理 CDC 事件的问题。具体来说，如果 PostgreSQL 数据库中的数据表存在 IDENTITY 列，并且该列没有主键索引，那么 PostgreSQL CDC 连接器可能会在处理 CDC 事件时抛出异常。

为了解决这个问题，我们在 PostgreSQL CDC 连接器中添加了一个新的配置项 enableIdentityColumnIndex。这个配置项默认值为 true，如果设置为 false，那么 PostgreSQL CDC 连接器将不会为 IDENTITY 列创建主键索引。

如果您使用的是 PostgreSQL CDC 连接器，并且遇到了上面提到的问题，请尝试将 enableIdentityColumnIndex 配置项设置为 false。如果您有任何其他问题，请随时提交 issue 到 Flink CDC 的 GitHub 仓库。