diff --git a/e2e_test/source/basic/alter/rate_limit_source_kafka.slt b/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
index 7d991083345a..e76cf72c0220 100644
--- a/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
+++ b/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
@@ -44,7 +44,7 @@ sleep 3s
 ############## Create MV on source
 
 statement ok
-SET STREAMING_RATE_LIMIT=0;
+SET SOURCE_RATE_LIMIT=0;
 
 statement ok
 create materialized view rl_mv1 as select count(*) from kafka_source;
@@ -56,7 +56,7 @@ statement ok
 create materialized view rl_mv3 as select count(*) from kafka_source;
 
 statement ok
-SET STREAMING_RATE_LIMIT=default;
+SET SOURCE_RATE_LIMIT=default;
 
 ############## MVs should have 0 records, since source has (rate_limit = 0)
 
@@ -82,11 +82,11 @@ select * from rl_mv3;
 
 skipif in-memory
 query I
-alter source kafka_source set streaming_rate_limit to 1000;
+alter source kafka_source set source_rate_limit to 1000;
 
 skipif in-memory
 query I
-alter source kafka_source set streaming_rate_limit to default;
+alter source kafka_source set source_rate_limit to default;
 
 skipif in-memory
 sleep 3s
diff --git a/e2e_test/source/basic/alter/rate_limit_table_kafka.slt b/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
index bf1fd6672d6e..d93687799cac 100644
--- a/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
+++ b/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
@@ -27,7 +27,7 @@ create table kafka_source (v1 int) with (
   topic = 'kafka_source',
   properties.bootstrap.server = 'message_queue:29092',
   scan.startup.mode = 'earliest',
-  streaming_rate_limit = 0
+  source_rate_limit = 0
 ) FORMAT PLAIN ENCODE JSON
 
 statement ok
@@ -61,11 +61,11 @@ select count(*) from kafka_source;
 
 skipif in-memory
 query I
-alter table kafka_source set streaming_rate_limit to 1000;
+alter table kafka_source set source_rate_limit to 1000;
 
 skipif in-memory
 query I
-alter table kafka_source set streaming_rate_limit to default;
+alter table kafka_source set source_rate_limit to default;
 
 skipif in-memory
 sleep 3s
diff --git a/e2e_test/source/basic/kafka.slt b/e2e_test/source/basic/kafka.slt
index dee5de1cbb53..40e9b4603611 100644
--- a/e2e_test/source/basic/kafka.slt
+++ b/e2e_test/source/basic/kafka.slt
@@ -391,7 +391,7 @@ create table s29 (id bytea) with (
   topic = 'kafka_source_format_bytes',
   properties.bootstrap.server = 'message_queue:29092',
   scan.startup.mode = 'earliest',
-  streaming_rate_limit = 200
+  source_rate_limit = 200
 ) FORMAT PLAIN ENCODE BYTES
 
 statement ok