Skip to content

Commit

Permalink
consume request count exceeds threshold {} placeholder no parameter fix.
Browse files Browse the repository at this point in the history
  • Loading branch information
iamgd67 committed Mar 27, 2024
1 parent d9c75ff commit e543b8a
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -901,7 +901,9 @@ public void run() {
if ((long) consumeRequestCache.size() * defaultLitePullConsumer.getPullBatchSize() > defaultLitePullConsumer.getPullThresholdForAll()) {
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={}", consumeRequestCache.size(), consumeRequestFlowControlTimes);
log.warn("The consume request count exceeds threshold {}, so do flow control, consume request count={}, flowControlTimes={}",
(int)Math.ceil((double)defaultLitePullConsumer.getPullThresholdForAll() / defaultLitePullConsumer.getPullBatchSize()),
consumeRequestCache.size(), consumeRequestFlowControlTimes);
}
return;
}
Expand Down

0 comments on commit e543b8a

Please sign in to comment.