feat(store): add stream cache config

common/src/main/java/com/automq/rocketmq/common/config/ProxyConfig.java

@@ -21,6 +21,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@SuppressWarnings({"FieldMayBeFinal", "FieldCanBeLocal"})
 public class ProxyConfig extends BaseConfig {
     private static final Logger LOGGER = LoggerFactory.getLogger(ProxyConfig.class);
 

common/src/main/java/com/automq/rocketmq/common/config/S3StreamConfig.java

@@ -17,6 +17,7 @@
 
 package com.automq.rocketmq.common.config;
 
+@SuppressWarnings({"FieldMayBeFinal", "FieldCanBeLocal"})
 public class S3StreamConfig {
     private String s3Endpoint;
     private String s3Region = "cn-hangzhou";
@@ -35,6 +36,12 @@ public class S3StreamConfig {
     private long streamObjectCompactionMaxSizeBytes = 10737418240L;
     private int streamObjectCompactionLivingTimeMinutes = 60;
 
+    private int objectBlockSize = 1048576;
+
+    // Cache
+    private int walCacheSize = 1024 * 1024 * 1024;
+    private int blockCacheSize = 1024 * 1024 * 1024;
+
     private int walObjectCompactionInterval = 20;
     private long walObjectCompactionCacheSize = 200 * 1024 * 1024;
     private int walObjectCompactionUploadConcurrency = 8;
@@ -95,6 +102,18 @@ public int streamObjectCompactionLivingTimeMinutes() {
         return streamObjectCompactionLivingTimeMinutes;
     }
 
+    public int objectBlockSize() {
+        return objectBlockSize;
+    }
+
+    public int walCacheSize() {
+        return walCacheSize;
+    }
+
+    public int blockCacheSize() {
+        return blockCacheSize;
+    }
+
     public int walObjectCompactionInterval() {
         return walObjectCompactionInterval;
     }

common/src/main/java/com/automq/rocketmq/common/config/StoreConfig.java

@@ -17,6 +17,7 @@
 
 package com.automq.rocketmq.common.config;
 
+@SuppressWarnings({"FieldMayBeFinal", "FieldCanBeLocal"})
 public class StoreConfig {
     private static final int PROCESSOR_NUMBER = Runtime.getRuntime().availableProcessors();
 

store/src/main/java/com/automq/rocketmq/store/S3StreamStore.java

@@ -226,6 +226,12 @@ private Config configFrom(S3StreamConfig streamConfig) {
         config.networkBaselineBandwidth(streamConfig.networkBaselineBandwidth());
         config.refillPeriodMs(streamConfig.refillPeriodMs());
 
+        config.objectBlockSize(streamConfig.objectBlockSize());
+
+        // Cache
+        config.walCacheSize(streamConfig.walCacheSize());
+        config.blockCacheSize(streamConfig.blockCacheSize());
+
         // Compaction config
         config.streamObjectCompactionIntervalMinutes(streamConfig.streamObjectCompactionIntervalMinutes());
         config.streamObjectCompactionMaxSizeBytes(streamConfig.streamObjectCompactionMaxSizeBytes());