Skip to content

Commit 6b96273

Browse files
authored
KAFKA-19345: Use ShareFetchUtils mock for DelayedShareFetchTest tests (#20765)
This patch wraps ShareFetchUtils static method `processFetchResponse` with MockedStatic to improve test isolation and also fixes some incorrect test results. Reviewers: Abhinav Dixit <[email protected]>, Andrew Schofield <[email protected]>
1 parent d6728d4 commit 6b96273

File tree

2 files changed

+154
-137
lines changed

2 files changed

+154
-137
lines changed

core/src/main/java/kafka/server/share/DelayedShareFetch.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -526,7 +526,6 @@ else if (isolationType == FetchIsolation.HIGH_WATERMARK)
526526
return offsetSnapshot.highWatermark();
527527
else
528528
return offsetSnapshot.lastStableOffset();
529-
530529
}
531530

532531
private LinkedHashMap<TopicIdPartition, LogReadResult> readFromLog(LinkedHashMap<TopicIdPartition, Long> topicPartitionFetchOffsets,

0 commit comments

Comments
 (0)