请教下 还是用flink cdc去读取的日志 这块有什么好的方法去获取数据的状态吗？

在使用 Flink CDC (Change Data Capture) 去读取 RDS (Relational Database Service) PostgreSQL 的日志时，通常期望能够捕获到数据的变更操作类型，比如 INSERT、UPDATE 或 DELETE。如果 Flink CDC 只提供了操作时间戳 op_ts 而没有提供操作类型，那么这确实是一个限制。

为了解决这个问题，你可以考虑以下几种方法：

1. 检查 Flink CDC Connector 版本：

   • 确保你使用的 Flink CDC Connector 是最新版本。老版本可能存在功能上的限制或 bug。

2. 自定义解析逻辑：

   • 如果 Flink CDC Connector 没有直接提供操作类型，你可能需要自定义解析逻辑来从捕获的变更数据中推断操作类型。
   • 例如，对于 UPDATE 操作，你可以检查捕获到的数据是否包含旧值和新值。如果同时包含旧值和新值，那么很可能是 UPDATE 操作。
   • 对于 DELETE 操作，可能只会捕获到旧值，没有新值。
   • 对于 INSERT 操作，通常只会捕获到新值。

3. 使用 PostgreSQL 的逻辑复制协议：

   • Flink CDC Connector 可能使用 PostgreSQL 的逻辑复制协议来捕获变更数据。在这种情况下，你可以查看逻辑复制协议的具体实现细节，了解如何从中提取操作类型。

4. 检查 Flink CDC Connector 的文档和配置：

   • 仔细阅读 Flink CDC Connector 的官方文档，查看是否有关于如何获取操作类型的说明。
   • 检查配置选项，看是否有与操作类型相关的配置参数。

5. 联系 Flink CDC Connector 的开发者或社区：

   • 如果你无法自行解决问题，可以尝试联系 Flink CDC Connector 的开发者或在相关社区提问，寻求帮助。

6. 考虑其他 CDC 工具：

   • 如果 Flink CDC Connector 无法满足你的需求，你可以考虑使用其他支持 PostgreSQL 的 CDC 工具，如 Debezium、Canal 等。这些工具可能提供了更丰富的功能，包括捕获操作类型。