diff --git a/broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java b/broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java
index 5b8b2fb9cec..45699221868 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java
@@ -17,7 +17,6 @@
 package org.apache.rocketmq.broker.coldctr;
 
 import java.util.ArrayList;
-import java.util.Comparator;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map.Entry;
@@ -141,20 +140,15 @@ private void clearDataAcc() {
     }
 
     private void sortAndDecelerate() {
-        List<Entry<String, Long>> configMapList = new ArrayList<Entry<String, Long>>(cgColdThresholdMapConfig.entrySet());
-        configMapList.sort(new Comparator<Entry<String, Long>>() {
-            @Override
-            public int compare(Entry<String, Long> o1, Entry<String, Long> o2) {
-                return (int)(o2.getValue() - o1.getValue());
-            }
-        });
+        List<Entry<String, Long>> configMapList = new ArrayList<>(cgColdThresholdMapConfig.entrySet());
+        configMapList.sort((o1, o2) -> (int)(o2.getValue() - o1.getValue()));
         Iterator<Entry<String, Long>> iterator = configMapList.iterator();
         int maxDecelerate = 3;
         while (iterator.hasNext() && maxDecelerate > 0) {
             Entry<String, Long> next = iterator.next();
             if (!isAdminConfig(next.getKey())) {
                 coldCtrStrategy.decelerate(next.getKey(), getThresholdByConsumerGroup(next.getKey()));
-                maxDecelerate --;
+                maxDecelerate--;
             }
         }
     }