diff --git a/src/connector/src/parser/unified/debezium.rs b/src/connector/src/parser/unified/debezium.rs
index 5a54a550e816d..589fdfc8cfc45 100644
--- a/src/connector/src/parser/unified/debezium.rs
+++ b/src/connector/src/parser/unified/debezium.rs
@@ -261,7 +261,7 @@ where
                     Err(AccessError::Undefined {
                         name: "_id".to_string(),
                         path: path[0].to_string(),
-                    })
+                    })?
                 }
             }
             ["after" | "before", "payload"] => self.access(&[path[0]], Some(&DataType::Jsonb)),
@@ -282,7 +282,7 @@ where
                         Err(AccessError::Undefined {
                             name: "_id".to_string(),
                             path: "id".to_string(),
-                        })
+                        })?
                     }
                 } else {
                     ret