Skip to content

Commit 859a2dd

Browse files
committed
Fixed naming
1 parent e494c99 commit 859a2dd

File tree

4 files changed

+4
-7
lines changed

4 files changed

+4
-7
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
import static io.kafbat.ui.model.rbac.permission.TopicAction.EDIT;
88
import static io.kafbat.ui.model.rbac.permission.TopicAction.VIEW;
99
import static java.util.stream.Collectors.toList;
10-
import static org.apache.commons.lang3.Strings.CI;
1110

1211
import io.kafbat.ui.api.TopicsApi;
1312
import io.kafbat.ui.config.ClustersProperties;
@@ -363,7 +362,7 @@ private Comparator<InternalTopic> getComparatorForTopic(
363362
case REPLICATION_FACTOR -> Comparator.comparing(InternalTopic::getReplicationFactor);
364363
case SIZE -> Comparator.comparing(InternalTopic::getSegmentSize);
365364
case MESSAGES_NUMBER -> Comparator.comparing(
366-
InternalTopic::getMessagesNumber,
365+
InternalTopic::getMessagesCount,
367366
Comparator.nullsLast(Long::compareTo)
368367
);
369368
default -> defaultComparator;

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,6 @@
1010
import lombok.Data;
1111
import org.apache.kafka.clients.admin.ConfigEntry;
1212
import org.apache.kafka.clients.admin.TopicDescription;
13-
import org.apache.kafka.common.TopicPartition;
14-
import org.jetbrains.annotations.NotNull;
1513

1614
@Data
1715
@Builder(toBuilder = true)
@@ -144,7 +142,7 @@ public static InternalTopic from(TopicDescription topicDescription,
144142
return topic.build();
145143
}
146144

147-
public @Nullable Long getMessagesNumber() {
145+
public @Nullable Long getMessagesCount() {
148146
Long result = null;
149147
if (cleanUpPolicy.equals(CleanupPolicy.DELETE)) {
150148
result = 0L;

contract-typespec/api/topics.tsp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ model Topic {
171171
bytesInPerSec?: float64;
172172
bytesOutPerSec?: float64;
173173
underReplicatedPartitions?: int32;
174-
messagesNumber?: int64 | null;
174+
messagesCount?: int64 | null;
175175
cleanUpPolicy?: CleanUpPolicy;
176176
partitions?: Partition[];
177177
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2748,7 +2748,7 @@ components:
27482748
type: array
27492749
items:
27502750
$ref: "#/components/schemas/Partition"
2751-
messagesNumber:
2751+
messagesCount:
27522752
type: integer
27532753
format: int64
27542754
nullable: true

0 commit comments

Comments
 (0)