From 3c32be5ace1847bc3181fbefe44ab5f505d967c1 Mon Sep 17 00:00:00 2001
From: James Yin <ywhjames@hotmail.com>
Date: Tue, 4 Aug 2020 17:32:32 +0800
Subject: [PATCH] fix GroupConsumeInfo#compareTo (#326)

---
 .../org/apache/rocketmq/console/model/GroupConsumeInfo.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java b/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java
index 27c5f92..5d81f2e 100644
--- a/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java
+++ b/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java
@@ -71,10 +71,9 @@ public class GroupConsumeInfo implements Comparable<GroupConsumeInfo> {
     @Override
     public int compareTo(GroupConsumeInfo o) {
         if (this.count != o.count) {
-            return o.count - this.count;
+            return Integer.compare(o.count, this.count);
         }
-
-        return (int) (o.diffTotal - diffTotal);
+        return Long.compare(o.diffTotal, this.diffTotal);
     }
 
     public int getConsumeTps() {