Skip to content

Commit 8f365e9

Browse files
committed
Fixed empty query
1 parent 6df0461 commit 8f365e9

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

api/src/main/java/io/kafbat/ui/service/index/FilterTopicIndex.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import static org.apache.commons.lang3.Strings.CI;
44

55
import io.kafbat.ui.model.InternalTopic;
6+
import java.util.ArrayList;
67
import java.util.List;
78
import java.util.stream.Stream;
89

@@ -15,6 +16,9 @@ public FilterTopicIndex(List<InternalTopic> topics) {
1516

1617
@Override
1718
public List<InternalTopic> find(String search, Boolean showInternal, String sort, Integer count) {
19+
if (sort == null || sort.isBlank()) {
20+
return new ArrayList<>(this.topics);
21+
}
1822
Stream<InternalTopic> stream = topics.stream().filter(topic -> !topic.isInternal()
1923
|| showInternal != null && showInternal)
2024
.filter(

api/src/main/java/io/kafbat/ui/service/index/LuceneTopicsIndex.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,9 @@ public List<InternalTopic> find(String search, Boolean showInternal, String sort
119119

120120
public List<InternalTopic> find(String search, Boolean showInternal,
121121
String sortField, Integer count, float minScore) {
122+
if (search == null || search.isBlank()) {
123+
return new ArrayList<>(this.topicMap.values());
124+
}
122125
closeLock.readLock().lock();
123126
try {
124127
Query nameQuery;

0 commit comments

Comments
 (0)