Skip to content

Commit 1e61f99

Browse files
committed
Expose messages number
1 parent 628e95a commit 1e61f99

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,7 @@ public static InternalTopic from(TopicDescription topicDescription,
147147
public Long getMessagesNumber() {
148148
Long result = null;
149149
if (cleanUpPolicy.equals(CleanupPolicy.DELETE)) {
150+
result = 0L;
150151
if (partitions != null && !partitions.isEmpty()) {
151152
for (InternalPartition partition : partitions.values()) {
152153
result += (partition.getOffsetMax() - partition.getOffsetMin());

0 commit comments

Comments
 (0)