Flink CDC问题：读取oracle19c在线日志提示 各位社区高手这个问题用怎样的思路能解决？

问题分析

根据您提供的错误信息和环境描述，ORA-01435: 用户不存在 是 Oracle 数据库中常见的权限或用户配置问题。此问题通常发生在以下场景中：

1. 用户未正确创建或未分配必要权限：Oracle CDC 使用 DBMS_LOGMNR 包解析在线日志，而该包需要特定的用户权限。
2. 容器数据库（CDB）与可插拔数据库（PDB）切换问题：在 Oracle 19c 中，CDB 和 PDB 的权限管理是分离的，CDC 操作可能需要在正确的容器中执行。
3. 补偿日志（Supplemental Logging）未启用：Oracle CDC 需要启用补偿日志以捕获变更数据。

解决方案

1. 确认用户是否存在并具有必要权限

首先，检查用于连接 Oracle 数据库的用户是否已正确创建，并确保其具有以下权限：

• 系统权限：

  GRANT SELECT ANY TRANSACTION TO C##DBZUSER;
  GRANT LOGMINING TO C##DBZUSER;
  GRANT EXECUTE ON DBMS_LOGMNR TO C##DBZUSER;
  

• 表级权限：

  GRANT SELECT ON V$LOGMNR_CONTENTS TO C##DBZUSER;
  GRANT SELECT ON V$ARCHIVED_LOG TO C##DBZUSER;
  GRANT SELECT ON V$LOGFILE TO C##DBZUSER;
  

• 验证权限：

  SELECT * FROM DBA_SYS_PRIVS WHERE GRANTEE = 'C##DBZUSER';
  SELECT TABLE_NAME FROM DBA_TAB_PRIVS WHERE GRANTEE = 'C##DBZUSER';
  

如果用户不存在，请使用以下命令创建用户并分配权限：

CREATE USER C##DBZUSER IDENTIFIED BY your_password CONTAINER=ALL;
GRANT CREATE SESSION TO C##DBZUSER CONTAINER=ALL;

2. 切换到正确的容器（CDB 或 PDB）

在 Oracle 19c 中，CDC 操作可能需要在特定的容器中执行。请确认当前会话是否在正确的容器中运行：

• 切换到 CDB：

  ALTER SESSION SET CONTAINER = CDB$ROOT;
  

• 切换到 PDB：

  ALTER SESSION SET CONTAINER = YOUR_PDB_NAME;
  

• 验证当前容器：

  SHOW CON_NAME;
  

确保 CDC 操作在目标 PDB 中执行。

3. 启用补偿日志（Supplemental Logging）

Oracle CDC 需要启用补偿日志以捕获变更数据。请按照以下步骤启用补偿日志：

• 全局补偿日志：

  ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
  

• 表级补偿日志：

  ALTER TABLE YOUR_SCHEMA.YOUR_TABLE ADD SUPPLEMENTAL LOG DATA (PRIMARY KEY) COLUMNS;
  

• 验证补偿日志状态：

  SELECT * FROM DBA_LOG_GROUPS WHERE TABLE_NAME = 'YOUR_TABLE_NAME';
  

4. 检查 DBMS_LOGMNR 包的调用

错误信息表明 DBMS_LOGMNR.START_LOGMNR 调用失败。请确保以下几点：

• 调用语法正确：

  BEGIN
  SYS.DBMS_LOGMNR.START_LOGMNR(
    OPTIONS => DBMS_LOGMNR.DICT_FROM_ONLINE_CATALOG + DBMS_LOGMNR.NO_ROWID_IN_STMT
  );
  END;
  

• 用户权限验证： 确保调用 DBMS_LOGMNR 的用户具有 EXECUTE 权限。

5. 检查 Flink CDC 配置

在 Flink CDC 中，确保以下配置正确无误：

• JDBC URL： 确保 JDBC URL 指向正确的 Oracle 实例和容器。例如：

  jdbc:oracle:thin:@//<host>:<port>/<service_name>
  

• 用户名和密码： 确保使用的用户名和密码与 Oracle 数据库中的用户一致。

• 其他参数： 如果使用 DataStream API，确保 tableList 参数包含正确的表名格式：

  tableList("yourSchema.yourTable")
  

总结与建议

1. 用户权限：确保 C##DBZUSER 用户已正确创建并分配了必要的权限。
2. 容器切换：确认操作在正确的容器（CDB 或 PDB）中执行。
3. 补偿日志：启用全局和表级补偿日志。
4. Flink 配置：检查 Flink CDC 的 JDBC URL、用户名、密码及其他相关参数。

如果问题仍未解决，建议进一步检查 Oracle 数据库的日志文件，定位具体的权限或配置问题。您可以复制页面截图提供更多信息，我可以进一步帮您分析问题原因。