diff --git a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java
index d11467745b..1734b81225 100644
--- a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java
+++ b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java
@@ -70,7 +70,7 @@ public DefaultBackPressureManager(BackPressureConfig config, Regulator regulator
 
     @Override
     public void start() {
-        this.checkerScheduler = Threads.newSingleThreadScheduledExecutor(ThreadUtils.createThreadFactory("back-pressure-checker-%d", false), LOGGER);
+        this.checkerScheduler = Threads.newSingleThreadScheduledExecutor(ThreadUtils.createThreadFactory("back-pressure-checker-%d", false), LOGGER, true, false);
         S3StreamKafkaMetricsManager.setBackPressureStateSupplier(this::stateMetrics);
     }