diff --git a/src/connector/src/parser/mod.rs b/src/connector/src/parser/mod.rs
index 448c98ec571ae..5c31408317f97 100644
--- a/src/connector/src/parser/mod.rs
+++ b/src/connector/src/parser/mod.rs
@@ -794,6 +794,9 @@ impl ByteStreamSourceParserImpl {
             (ProtocolProperties::Plain, EncodingProperties::Csv(config)) => {
                 CsvParser::new(rw_columns, *config, source_ctx).map(Self::Csv)
             }
+            (ProtocolProperties::Plain, EncodingProperties::Json(_config)) => {
+                JsonParser::new(parser_config.specific, rw_columns, source_ctx).map(Self::Json)
+            }
             (ProtocolProperties::DebeziumMongo, EncodingProperties::Json(_)) => {
                 DebeziumMongoJsonParser::new(rw_columns, source_ctx).map(Self::DebeziumMongoJson)
             }