ji-seung-ryu commented on code in PR #19786:
URL: https://github.com/apache/kafka/pull/19786#discussion_r2105832275
##########
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##########
@@ -790,6 +789,27 @@ public void
testCachedTopicPartitionsForValidShareSessions() {
String groupId = "grp";
Uuid memberId1 = Uuid.randomUuid();
Uuid memberId2 = Uuid.randomUuid();
+ SharePartition sp0 = mock(SharePartition.class);
+ SharePartition sp1 = mock(SharePartition.class);
+ SharePartition sp2 = mock(SharePartition.class);
+ SharePartition sp3 = mock(SharePartition.class);
+
+
when(sp0.releaseAcquiredRecords(ArgumentMatchers.eq(String.valueOf(memberId1)))).thenReturn(CompletableFuture.completedFuture(null));
+
when(sp1.releaseAcquiredRecords(ArgumentMatchers.eq(String.valueOf(memberId1)))).thenReturn(CompletableFuture.completedFuture(null));
+
when(sp2.releaseAcquiredRecords(ArgumentMatchers.eq(String.valueOf(memberId1)))).thenReturn(CompletableFuture.completedFuture(null));
+
when(sp3.releaseAcquiredRecords(ArgumentMatchers.eq(String.valueOf(memberId1)))).thenReturn(CompletableFuture.completedFuture(null));
+
+ SharePartitionCache partitionCache = new SharePartitionCache();
+ partitionCache.put(new SharePartitionKey(groupId, tp0), sp0);
+ partitionCache.put(new SharePartitionKey(groupId, tp1), sp1);
+ partitionCache.put(new SharePartitionKey(groupId, tp2), sp2);
+ partitionCache.put(new SharePartitionKey(groupId, tp3), sp3);
Review Comment:
okay, I will remove sp3.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
