We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7e8776d commit 8125b80Copy full SHA for 8125b80
core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java
@@ -27,9 +27,6 @@
27
import com.automq.stream.s3.Config;
28
import com.automq.stream.s3.S3Storage;
29
import com.automq.stream.s3.S3StreamClient;
30
-import com.automq.stream.s3.backpressure.BackPressureManager;
31
-import com.automq.stream.s3.backpressure.DefaultBackPressureManager;
32
-import com.automq.stream.s3.backpressure.Regulator;
33
import com.automq.stream.s3.cache.S3BlockCache;
34
import com.automq.stream.s3.cache.blockcache.DefaultObjectReaderFactory;
35
import com.automq.stream.s3.cache.blockcache.ObjectReaderFactory;
0 commit comments