flink oracle cdc 读取数据一直为null，有大佬知道么？

1. 问题描述： 用户在使用Flink Oracle CDC读取数据时，发现所有数据字段一直为null，寻求解决此问题的方法。

2. 背景信息： Flink Oracle CDC通过Debezium连接器捕获Oracle数据库的变化数据流（CDC），将数据库的增删改操作转换为事件流。当遇到所有数据字段均为null的情况，可能与数据源配置、Debezium配置或数据类型映射有关。

3. 解决方案：

   • 步骤1：检查连接器配置
     确认debezium.connector.oracle.log.mining.strategy配置是否正确设置，推荐使用online_catalog策略以获取最准确的数据变更信息。同时，检查连接Oracle数据库的URL、用户名和密码等基本信息是否无误。

   • 步骤2：验证数据类型映射
     检查Oracle表中的数据类型与Flink SQL中定义的类型是否匹配，不匹配可能导致解析错误。例如，如果Oracle中的NUMBER类型映射到Flink的非字符串类型，但实际包含非数值字符，可能会被解析为null。

   • 步骤3：查看日志并调整脏数据处理模式
     查看Flink作业的日志，寻找是否有因数据格式不正确导致的解析失败警告。可以考虑调整Debezium的debezium.event.deserialization.failure.handling.mode参数为warn或ignore来处理潜在的脏数据问题，并观察是否改善情况。

   • 步骤4：确认Oracle数据库日志及权限
     确保Oracle数据库的redo log已启用且Flink Oracle CDC使用的用户具有足够的权限访问所需的redo logs和系统表。

4. 注意事项：

   • 日志分析：详细分析Flink作业日志是定位问题的关键，特别是Debezium相关的警告和错误信息。
   • 版本兼容性：确认使用的Flink、Debezium以及Oracle JDBC驱动的版本之间兼容，避免因版本不匹配引起的问题。
   • 网络与权限：确保Flink任务运行环境能够顺利访问Oracle数据库，没有网络阻隔或防火墙限制。

5. 示例代码： 无需提供完整代码示例，因为问题在于配置与排查，而非代码实现。重点在于检查和调整上述提到的配置项。

6. 参考资料： 上述建议基于知识库中关于Postgres CDC的配置经验进行类比推理，虽然直接针对Oracle CDC的资料未直接给出，但原理相似，可参考处理思路进行问题排查。

请按照上述步骤逐一排查，通常情况下，数据一直为null的问题可以通过正确的配置调整和环境检查得到解决。