From 14376b6354b4820632c909cfc62ae2ef8152ce03 Mon Sep 17 00:00:00 2001 From: wqliang Date: Fri, 8 May 2020 11:29:34 +0800 Subject: [PATCH] fix potential overflow and limit upper bound --- .../webank/defibus/broker/client/AdjustQueueNumStrategy.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java b/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java index da9b5c34ae..36bf8f3919 100644 --- a/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java +++ b/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java @@ -84,7 +84,8 @@ private void adjustQueueNumByConsumerCount(String topic, AdjustType scaleType) { case DECREASE_QUEUE_NUM: adjustWriteQueueNumByConsumerCount(topic, 0, scaleType); - long delayTimeMillis = deFiBrokerController.getDeFiBusBrokerConfig().getScaleQueueSizeDelayTimeMinute() * 60 * 1000; + long delayTimeMinutes = Math.min(deFiBrokerController.getDeFiBusBrokerConfig().getScaleQueueSizeDelayTimeMinute(), 10); + long delayTimeMillis = delayTimeMinutes * 60 * 1000; adjustReadQueueNumByConsumerCount(topic, delayTimeMillis, scaleType); break; }