diff --git a/src/datanode/src/region_server.rs b/src/datanode/src/region_server.rs
index f5f70ff37e..8625de02b3 100644
--- a/src/datanode/src/region_server.rs
+++ b/src/datanode/src/region_server.rs
@@ -410,6 +410,24 @@ impl RegionServer {
 #[async_trait]
 impl RegionServerHandler for RegionServer {
     async fn handle(&self, request: region_request::Body) -> ServerResult<RegionResponseV1> {
+        if matches!(request, region_request::Body::Inserts(_)) {
+            let resp = self
+                .handle_batch_body(request)
+                .await
+                .map_err(BoxedError::new)
+                .context(ExecuteGrpcRequestSnafu)?;
+            return Ok(RegionResponseV1 {
+                header: Some(ResponseHeader {
+                    status: Some(Status {
+                        status_code: StatusCode::Success as _,
+                        ..Default::default()
+                    }),
+                }),
+                affected_rows: resp.affected_rows as _,
+                extensions: resp.extensions,
+            });
+        }
+
         let bundle = convert_body_to_requests(request)
             .context(BuildRegionRequestsSnafu)
             .map_err(BoxedError::new)
@@ -941,7 +959,7 @@ impl RegionServerInner {
         //     }
         // }
 
-        todo!()
+        Ok(RegionResponse::new(0))
     }
 
     fn set_region_status_not_ready(