fix(topicdata): no topic data when 1 record with newest sort (#1466)

tchiotludo · Apr 26, 2023 · d898b46 · d898b46
1 parent 4713261
commit d898b46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/akhq/repositories/RecordRepository.java b/src/main/java/org/akhq/repositories/RecordRepository.java
@@ -408,7 +408,7 @@ private Optional<EndOffsetBound> getOffsetForSortNewest(KafkaConsumer<byte[], by
                     last = options.after.get(partition.getId()) - 1;
                 }
 
-                if (last == partition.getFirstOffset() || last < 0) {
+                if (last < 0) {
                     consumer.close();
                     return null;
                 } else if (!(last - pollSizePerPartition < first)) {