style: fix lint

Signed-off-by: Ning Yu <[email protected]>

Author: Chillax-0v0

core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java

@@ -16,13 +16,15 @@
 
 import com.automq.stream.utils.ThreadUtils;
 import com.automq.stream.utils.Threads;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import static kafka.automq.backpressure.BackPressureConfig.RECONFIGURABLE_CONFIGS;
 

core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java

@@ -11,9 +11,6 @@
 
 package kafka.log.stream.s3;
 
-import com.automq.stream.s3.backpressure.BackPressureManager;
-import com.automq.stream.s3.backpressure.DefaultBackPressureManager;
-import com.automq.stream.s3.backpressure.Regulator;
 import kafka.autobalancer.metricsreporter.metric.Derivator;
 import kafka.log.stream.s3.metadata.StreamMetadataManager;
 import kafka.log.stream.s3.network.ControllerRequestSender;

s3stream/src/main/java/com/automq/stream/utils/ThreadUtils.java

@@ -11,13 +11,15 @@
 
 package com.automq.stream.utils;
 
-import io.netty.util.concurrent.FastThreadLocalThread;
+import org.slf4j.Logger;
+import org.slf4j.helpers.NOPLogger;
+
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
-import org.slf4j.Logger;
-import org.slf4j.helpers.NOPLogger;
+
+import io.netty.util.concurrent.FastThreadLocalThread;
 
 /**
  * Utilities for working with threads.