From cf50aa0ca7a405f020937ffecb657f14c696026a Mon Sep 17 00:00:00 2001
From: xxchan <xxchan22f@gmail.com>
Date: Wed, 6 Mar 2024 11:00:44 +0800
Subject: [PATCH] add rate_limit

---
 proto/stream_plan.proto                      | 2 +-
 src/stream/src/from_proto/source_backfill.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/proto/stream_plan.proto b/proto/stream_plan.proto
index 39076a743bead..09268b7f6660e 100644
--- a/proto/stream_plan.proto
+++ b/proto/stream_plan.proto
@@ -214,7 +214,7 @@ message SourceBackfillNode {
   string source_name = 8;
   map<string, string> with_properties = 6;
   // Streaming rate limit
-  // optional uint32 rate_limit = 9;
+  optional uint32 rate_limit = 9;
 
   // fields above are the same as StreamSource
 
diff --git a/src/stream/src/from_proto/source_backfill.rs b/src/stream/src/from_proto/source_backfill.rs
index 9d52d58ccd01c..f0c38e67f115d 100644
--- a/src/stream/src/from_proto/source_backfill.rs
+++ b/src/stream/src/from_proto/source_backfill.rs
@@ -52,7 +52,7 @@ impl ExecutorBuilder for KafkaBackfillExecutorBuilder {
 
         let source_ctrl_opts = SourceCtrlOpts {
             chunk_size: params.env.config().developer.chunk_size,
-            rate_limit: None,
+            rate_limit: node.rate_limit,
         };
 
         let source_column_ids: Vec<_> = source_desc_builder