From aea1d33f8eb8b2206d4331e8e8acc00837bf6097 Mon Sep 17 00:00:00 2001
From: 67 <67@gd67.com>
Date: Tue, 26 Mar 2024 17:04:44 +0800
Subject: [PATCH] consume request count exceeds threshold {} placeholder no
 parameter fix.

---
 .../client/impl/consumer/DefaultLitePullConsumerImpl.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
index ecff7565ee58..78dafd0ff72f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -902,7 +902,7 @@ public void run() {
                     scheduledThreadPoolExecutor.schedule(this, PULL_TIME_DELAY_MILLS_WHEN_CACHE_FLOW_CONTROL, TimeUnit.MILLISECONDS);
                     if ((consumeRequestFlowControlTimes++ % 1000) == 0) {
                         log.warn("The consume request count exceeds threshold {}, so do flow control, consume request count={}, flowControlTimes={}",
-                                (int)Math.ceil((double)defaultLitePullConsumer.getPullThresholdForAll()/defaultLitePullConsumer.getPullBatchSize()),
+                                (int)Math.ceil((double)defaultLitePullConsumer.getPullThresholdForAll() / defaultLitePullConsumer.getPullBatchSize()),
                                 consumeRequestCache.size(), consumeRequestFlowControlTimes);
                     }
                     return;