BE: Quick fix on messages count calculation

germanosin · germanosin · commit 1ac238e98ff8 · 2025-09-15T13:34:47.000+02:00
diff --git a/api/src/main/java/io/kafbat/ui/model/InternalTopic.java b/api/src/main/java/io/kafbat/ui/model/InternalTopic.java
@@ -148,7 +148,9 @@ public static InternalTopic from(TopicDescription topicDescription,
       result = 0L;
       if (partitions != null && !partitions.isEmpty()) {
         for (InternalPartition partition : partitions.values()) {
-          result += (partition.getOffsetMax() - partition.getOffsetMin());
+          if (partition.getOffsetMin() != null && partition.getOffsetMax() != null) {
+            result += (partition.getOffsetMax() - partition.getOffsetMin());
+          }
         }
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,9 @@ public static InternalTopic from(TopicDescription topicDescription,`
`148`	`148`	`result = 0L;`
`149`	`149`	`if (partitions != null && !partitions.isEmpty()) {`
`150`	`150`	`for (InternalPartition partition : partitions.values()) {`
`151`		`- result += (partition.getOffsetMax() - partition.getOffsetMin());`
	`151`	`+ if (partition.getOffsetMin() != null && partition.getOffsetMax() != null) {`
	`152`	`+ result += (partition.getOffsetMax() - partition.getOffsetMin());`
	`153`	`+ }`
`152`	`154`	`}`
`153`	`155`	`}`
`154`	`156`	`}`