Skip to content

Commit 845faa9

Browse files
committed
BE: Set default message polling mode
address review comments
1 parent cac3a28 commit 845faa9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public Mono<ResponseEntity<Flux<TopicMessageEventDTO>>> getTopicMessagesV2(Strin
118118
if (cursor != null) {
119119
messagesFlux = messagesService.loadMessages(getCluster(clusterName), topicName, cursor);
120120
} else {
121-
var pollingMode = mode == null ? PollingModeDTO.EARLIEST : mode;
121+
var pollingMode = mode == null ? PollingModeDTO.LATEST : mode;
122122
messagesFlux = messagesService.loadMessages(
123123
getCluster(clusterName),
124124
topicName,

0 commit comments

Comments
 (0)