Debezium连接Oracle 19c在快照最终阶段触发Null-Pointer Exception

你遇到的空指针异常核心原因是Debezium连接Oracle的用户缺少元数据查询权限，在读取表结构环节无法获取到有效表元数据，代码未做非空校验直接调用对象方法触发NPE，不属于Kafka连接问题，属于数据库侧权限配置缺失。

基础连接与日志读取权限 #

• CREATE SESSION
• SELECT ON V_$DATABASE
• SELECT ON V_$LOG
• SELECT ON V_$LOGFILE
• SELECT ON V_$ARCHIVED_LOG
• SELECT ON V_$PARAMETER
• SELECT ON V_$TRANSACTION
• SELECT ON V_$SESSION
• SELECT ON V_$MYSTAT
• SELECT ON V_$LOCK
• SELECT ON V_$THREAD
• SELECT ON V_$TRANSACTION_ENQUEUE
• SELECT ON DBA_TABLESPACES

元数据查询权限（本次崩溃关联权限） #

• SELECT ANY TABLE（可根据实际捕获范围缩小至指定schema下的表）
• SELECT ON DBA_OBJECTS
• SELECT ON DBA_TABLES
• SELECT ON DBA_TAB_COLUMNS
• SELECT ON DBA_CONSTRAINTS
• SELECT ON DBA_CONS_COLUMNS
• SELECT ON DBA_INDEXES
• SELECT ON DBA_IND_COLUMNS
• SELECT ON DBA_TAB_COMMENTS
• SELECT ON DBA_COL_COMMENTS

LogMiner适配器专属权限 #

• EXECUTE ON SYS.DBMS_LOGMNR
• EXECUTE ON SYS.DBMS_LOGMNR_D
• SELECT ON V_$LOGMNR_CONTENTS
• LOGMINING（Oracle 12c及以上版本必填）

1. 使用SYS或拥有DBA权限的用户执行以下赋权语句，将debezium_user替换为你实际使用的连接用户名：

GRANT CREATE SESSION TO debezium_user;
GRANT SELECT ON V_$DATABASE TO debezium_user;
GRANT SELECT ON V_$LOG TO debezium_user;
GRANT SELECT ON V_$LOGFILE TO debezium_user;
GRANT SELECT ON V_$ARCHIVED_LOG TO debezium_user;
GRANT SELECT ON V_$PARAMETER TO debezium_user;
GRANT SELECT ON V_$TRANSACTION TO debezium_user;
GRANT SELECT ON V_$SESSION TO debezium_user;
GRANT SELECT ON V_$MYSTAT TO debezium_user;
GRANT SELECT ON V_$LOCK TO debezium_user;
GRANT SELECT ON V_$THREAD TO debezium_user;
GRANT SELECT ON V_$TRANSACTION_ENQUEUE TO debezium_user;
GRANT SELECT ON DBA_TABLESPACES TO debezium_user;
-- 元数据权限
GRANT SELECT ANY TABLE TO debezium_user;
GRANT SELECT ON DBA_OBJECTS TO debezium_user;
GRANT SELECT ON DBA_TABLES TO debezium_user;
GRANT SELECT ON DBA_TAB_COLUMNS TO debezium_user;
GRANT SELECT ON DBA_CONSTRAINTS TO debezium_user;
GRANT SELECT ON DBA_CONS_COLUMNS TO debezium_user;
GRANT SELECT ON DBA_INDEXES TO debezium_user;
GRANT SELECT ON DBA_IND_COLUMNS TO debezium_user;
GRANT SELECT ON DBA_TAB_COMMENTS TO debezium_user;
GRANT SELECT ON DBA_COL_COMMENTS TO debezium_user;
-- LogMiner权限
GRANT EXECUTE ON SYS.DBMS_LOGMNR TO debezium_user;
GRANT EXECUTE ON SYS.DBMS_LOGMNR_D TO debezium_user;
GRANT SELECT ON V_$LOGMNR_CONTENTS TO debezium_user;
GRANT LOGMINING TO debezium_user;

2. 清空Kafka中该连接器对应的offset主题、schema历史主题的存量数据，避免脏数据影响后续启动。
3. 重启Debezium连接器测试，若仍有异常可先配置table.include.list仅捕获单张测试表，排查是否存在特殊表结构（如不支持的字段类型、外部表、临时表）导致的元数据读取异常。

内容的提问来源于stack exchange，提问作者Vierheller