add rate_limit

risingwavelabs · Mar 6, 2024 · cf50aa0 · cf50aa0
1 parent de217fd
commit cf50aa0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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