diff --git a/java/yb-pgsql/src/test/java/org/yb/pgsql/TestPgRegressReplicationSlot.java b/java/yb-pgsql/src/test/java/org/yb/pgsql/TestPgRegressReplicationSlot.java
index f530b46dbc50..c680949c3876 100644
--- a/java/yb-pgsql/src/test/java/org/yb/pgsql/TestPgRegressReplicationSlot.java
+++ b/java/yb-pgsql/src/test/java/org/yb/pgsql/TestPgRegressReplicationSlot.java
@@ -35,6 +35,7 @@ protected Map<String, String> getTServerFlags() {
         "ysql_yb_enable_replication_commands,yb_enable_cdc_consistent_snapshot_streams");
     flagMap.put("ysql_yb_enable_replication_commands", "true");
     flagMap.put("yb_enable_cdc_consistent_snapshot_streams", "true");
+    flagMap.put("ysql_TEST_enable_replication_slot_consumption", "true");
     return flagMap;
   }
 
@@ -45,6 +46,7 @@ protected Map<String, String> getMasterFlags() {
         "ysql_yb_enable_replication_commands,yb_enable_cdc_consistent_snapshot_streams");
     flagMap.put("ysql_yb_enable_replication_commands", "true");
     flagMap.put("yb_enable_cdc_consistent_snapshot_streams", "true");
+    flagMap.put("ysql_TEST_enable_replication_slot_consumption", "true");
     return flagMap;
   }
 
diff --git a/src/yb/integration-tests/cdcsdk_ysql-test.cc b/src/yb/integration-tests/cdcsdk_ysql-test.cc
index f3dddedbf9ea..a3e33fd187b1 100644
--- a/src/yb/integration-tests/cdcsdk_ysql-test.cc
+++ b/src/yb/integration-tests/cdcsdk_ysql-test.cc
@@ -7666,6 +7666,7 @@ TEST_F(CDCSDKYsqlTest, TestReplicationSlotDropWithActiveInvalid) {
   ANNOTATE_UNPROTECTED_WRITE(FLAGS_ysql_cdc_active_replication_slot_window_ms) =
       10000 * yb::kTimeMultiplier;
   ANNOTATE_UNPROTECTED_WRITE(FLAGS_yb_enable_cdc_consistent_snapshot_streams) = true;
+  ANNOTATE_UNPROTECTED_WRITE(FLAGS_ysql_TEST_enable_replication_slot_consumption) = true;
 
   ASSERT_OK(SetUpWithParams(3, 1, false));
   auto table =