consume request count exceeds threshold {} placeholder no parameter fix.

apache · Mar 26, 2024 · 0525707 · 0525707
1 parent 1683727
commit 0525707
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...t/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/...t/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={}",
-                                Math.ceil((double)defaultLitePullConsumer.getPullThresholdForAll()/defaultLitePullConsumer.getPullBatchSize()),
+                                (int)Math.ceil((double)defaultLitePullConsumer.getPullThresholdForAll()/defaultLitePullConsumer.getPullBatchSize()),
                                 consumeRequestCache.size(), consumeRequestFlowControlTimes);
                     }
                     return;