feat(s3stream): add network rate limiter for s3 wal to export metrics (#1859)

Signed-off-by: SSpirits <[email protected]>

Author: ShadowySpirits

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

@@ -177,12 +177,16 @@ protected WriteAheadLog buildWAL() {
             case "file":
                 return BlockWALService.builder(uri).config(config).build();
             case "s3":
-                ObjectStorage walObjectStorage = ObjectStorageFactory.instance().builder(BucketURI.parse(config.walConfig()))
+                ObjectStorage walObjectStorage = ObjectStorageFactory.instance()
+                    .builder(BucketURI.parse(config.walConfig()))
+                    .inboundLimiter(networkInboundLimiter)
+                    .outboundLimiter(networkOutboundLimiter)
                     .tagging(config.objectTagging())
                     .threadPrefix("s3-wal")
                     .build();
 
-                ObjectWALConfig.Builder configBuilder = ObjectWALConfig.builder().withURI(uri)
+                ObjectWALConfig.Builder configBuilder = ObjectWALConfig.builder()
+                    .withURI(uri)
                     .withClusterId(brokerServer.clusterId())
                     .withNodeId(config.nodeId())
                     .withEpoch(config.nodeEpoch());