From 8eb6d7073eaf752038c6878f2ce9c52d51da5ce9 Mon Sep 17 00:00:00 2001 From: iliax Date: Sat, 5 Aug 2023 17:25:46 +0400 Subject: [PATCH] wip --- .../com/provectus/kafka/ui/emitter/SeekOperations.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/emitter/SeekOperations.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/emitter/SeekOperations.java index fa5f179cf8..03fac96da7 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/emitter/SeekOperations.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/emitter/SeekOperations.java @@ -61,19 +61,19 @@ public class SeekOperations { */ @VisibleForTesting static Map getOffsetsForSeek(Consumer consumer, - OffsetsInfo offsetsInfo, - SeekTypeDTO seekType, - @Nullable Map seekTo) { + OffsetsInfo offsetsInfo, + SeekTypeDTO seekType, + @Nullable Map seekTo) { switch (seekType) { case LATEST: return consumer.endOffsets(offsetsInfo.getNonEmptyPartitions()); case BEGINNING: return consumer.beginningOffsets(offsetsInfo.getNonEmptyPartitions()); case OFFSET: - Preconditions.checkNotNull(offsetsInfo); + Preconditions.checkNotNull(seekTo); return fixOffsets(offsetsInfo, seekTo); case TIMESTAMP: - Preconditions.checkNotNull(offsetsInfo); + Preconditions.checkNotNull(seekTo); return offsetsForTimestamp(consumer, offsetsInfo, seekTo); default: throw new IllegalStateException();