From f8c12d31aed7d82da64d3dfa25afc0b79d4d1f92 Mon Sep 17 00:00:00 2001
From: qianye <wuxingcan.wxc@alibaba-inc.com>
Date: Tue, 3 Sep 2024 17:07:27 +0800
Subject: [PATCH] revert

---
 .../rocketmq/store/dledger/MessageStoreTestBase.java       | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java b/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java
index c4d9f0727b97..a21806ffcf6f 100644
--- a/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java
+++ b/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java
@@ -16,7 +16,6 @@
  */
 package org.apache.rocketmq.store.dledger;
 
-import com.google.common.util.concurrent.RateLimiter;
 import io.openmessaging.storage.dledger.DLedgerConfig;
 import io.openmessaging.storage.dledger.DLedgerServer;
 import java.io.File;
@@ -123,13 +122,7 @@ protected DefaultMessageStore createMessageStore(String base, boolean createAbor
     }
 
     protected void doPutMessages(MessageStore messageStore, String topic, int queueId, int num, long beginLogicsOffset) throws UnknownHostException {
-        RateLimiter rateLimiter = RateLimiter.create(100);
-        MessageStoreConfig storeConfig = messageStore.getMessageStoreConfig();
-        boolean limitAppendRate = storeConfig.isEnableDLegerCommitLog();
         for (int i = 0; i < num; i++) {
-            if (limitAppendRate) {
-                rateLimiter.acquire();
-            }
             MessageExtBrokerInner msgInner = buildMessage();
             msgInner.setTopic(topic);
             msgInner.setQueueId(queueId);