feat(topic-data): sort topic records by timestamp (#337)

Co-authored-by: Raj Kumar Mondol <rajkumar.mondol@tesco.com>
tchiotludo · Aug 7, 2020 · 00bf22a · 00bf22a
1 parent 840fcd3
commit 00bf22a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/org/akhq/repositories/RecordRepository.java b/src/main/java/org/akhq/repositories/RecordRepository.java
@@ -89,6 +89,8 @@ private List<Record> consumeOldest(Topic topic, Options options) {
 
         consumer.close();
 
+        list.sort(Comparator.comparing(Record::getTimestamp));
+
         return list;
     }
 
@@ -227,6 +229,7 @@ private List<Record> consumeNewest(Topic topic, Options options) {
                 return Stream.of(list);
             })
             .flatMap(List::stream)
+            .sorted(Comparator.comparing(Record::getTimestamp).reversed())
             .collect(Collectors.toList());
     }