Skip to content

Commit 8f9c634

Browse files
wernerdvHaarolean
andauthored
BE: Set default message polling mode (#649)
Co-authored-by: Roman Zabaluev <[email protected]>
1 parent 5e510f9 commit 8f9c634

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,10 +118,11 @@ 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.LATEST : mode;
121122
messagesFlux = messagesService.loadMessages(
122123
getCluster(clusterName),
123124
topicName,
124-
ConsumerPosition.create(checkNotNull(mode), checkNotNull(topicName), partitions, timestamp, offset),
125+
ConsumerPosition.create(pollingMode, checkNotNull(topicName), partitions, timestamp, offset),
125126
stringFilter,
126127
smartFilterId,
127128
limit,

0 commit comments

Comments
 (0)