BE: Fixes #498 Added sort by number of messages

Author: germanosin

api/src/main/java/io/kafbat/ui/controller/TopicsController.java

@@ -362,6 +362,7 @@ private Comparator<InternalTopic> getComparatorForTopic(
       case OUT_OF_SYNC_REPLICAS -> Comparator.comparing(t -> t.getReplicas() - t.getInSyncReplicas());
       case REPLICATION_FACTOR -> Comparator.comparing(InternalTopic::getReplicationFactor);
       case SIZE -> Comparator.comparing(InternalTopic::getSegmentSize);
+      case MESSAGES_NUMBER ->  Comparator.comparing(InternalTopic::getMessagesNumber);
       default -> defaultComparator;
     };
   }

api/src/main/java/io/kafbat/ui/model/InternalTopic.java

@@ -11,6 +11,7 @@
 import org.apache.kafka.clients.admin.ConfigEntry;
 import org.apache.kafka.clients.admin.TopicDescription;
 import org.apache.kafka.common.TopicPartition;
+import org.jetbrains.annotations.NotNull;
 
 @Data
 @Builder(toBuilder = true)
@@ -143,4 +144,13 @@ public static InternalTopic from(TopicDescription topicDescription,
     return topic.build();
   }
 
+  public long getMessagesNumber() {
+    long result = 0;
+    if (partitions != null && !partitions.isEmpty()) {
+      for (InternalPartition partition : partitions.values()) {
+        result += (partition.getOffsetMax() - partition.getOffsetMin());
+      }
+    }
+    return result;
+  }
 }

contract-typespec/api/topics.tsp

@@ -156,6 +156,7 @@ enum TopicColumnsToSort {
   TOTAL_PARTITIONS,
   REPLICATION_FACTOR,
   SIZE,
+  MESSAGES_NUMBER
 }
 
 model Topic {

contract/src/main/resources/swagger/kafbat-ui-api.yaml

@@ -2692,6 +2692,7 @@ components:
         - TOTAL_PARTITIONS
         - REPLICATION_FACTOR
         - SIZE
+        - MESSAGES_NUMBER
 
     SchemaColumnsToSort:
       type: string