diff --git a/src/connector/src/parser/debezium/mongo_json_parser.rs b/src/connector/src/parser/debezium/mongo_json_parser.rs
index 910b5a3e0131d..7c3b01fd1291e 100644
--- a/src/connector/src/parser/debezium/mongo_json_parser.rs
+++ b/src/connector/src/parser/debezium/mongo_json_parser.rs
@@ -20,7 +20,7 @@ use risingwave_common::types::DataType;
 use simd_json::{BorrowedValue, Mutable};
 
 use crate::only_parse_payload;
-use crate::parser::unified::debezium::{DebeziumChangeEvent, MongoProjeciton};
+use crate::parser::unified::debezium::{DebeziumChangeEvent, MongoProjection};
 use crate::parser::unified::json::{JsonAccess, JsonParseOptions};
 use crate::parser::unified::util::apply_row_operation_on_stream_chunk_writer;
 use crate::parser::{ByteStreamSourceParser, SourceStreamChunkRowWriter, WriteGuard};
@@ -97,7 +97,7 @@ impl DebeziumMongoJsonParser {
 
         let accessor = JsonAccess::new_with_options(payload, &JsonParseOptions::DEBEZIUM);
 
-        let row_op = DebeziumChangeEvent::with_value(MongoProjeciton::new(accessor));
+        let row_op = DebeziumChangeEvent::with_value(MongoProjection::new(accessor));
 
         apply_row_operation_on_stream_chunk_writer(row_op, &mut writer)
     }
diff --git a/src/connector/src/parser/unified/debezium.rs b/src/connector/src/parser/unified/debezium.rs
index 9155b5910cf58..e16df28aebdf2 100644
--- a/src/connector/src/parser/unified/debezium.rs
+++ b/src/connector/src/parser/unified/debezium.rs
@@ -136,7 +136,7 @@ where
     }
 }
 
-pub struct MongoProjeciton<A> {
+pub struct MongoProjection<A> {
     accessor: A,
 }
 
@@ -183,13 +183,13 @@ pub fn extract_bson_id(id_type: &DataType, bson_doc: &serde_json::Value) -> anyh
 };
     Ok(id)
 }
-impl<A> MongoProjeciton<A> {
+impl<A> MongoProjection<A> {
     pub fn new(accessor: A) -> Self {
         Self { accessor }
     }
 }
 
-impl<A> Access for MongoProjeciton<A>
+impl<A> Access for MongoProjection<A>
 where
     A: Access,
 {