Skip to content

Commit

Permalink
feat(backpressure): stop and remove all scheduled tasks on shutdown (#…
Browse files Browse the repository at this point in the history
…2207)

Signed-off-by: Ning Yu <ningyu@automq.com>
  • Loading branch information
Chillax-0v0 authored Dec 3, 2024
1 parent 46c0e76 commit 1cdce66
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}

Expand Down

0 comments on commit 1cdce66

Please sign in to comment.