(kafka) branch trunk updated: KAFKA-20610: Minor - correcting test and scala imports (4/N) (#22438)

[mittal]

This is an automated email from the ASF dual-hosted git repository.

apoorvmittal10 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 115d6d31858 KAFKA-20610: Minor - correcting test and scala imports 
(4/N) (#22438)
115d6d31858 is described below

commit 115d6d31858b13704128505ea46ccedb85d818e0
Author: Apoorv Mittal <apoorvmitta...@gmail.com>
AuthorDate: Mon Jun 1 17:02:52 2026 +0100

    KAFKA-20610: Minor - correcting test and scala imports (4/N) (#22438)
    
    Minor PR to correct test where the mock was missing during the recent
    refactor. Also correcting the scala imports.
    
    Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>
---
 core/src/test/java/kafka/server/share/SharePartitionTest.java  | 1 +
 core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/core/src/test/java/kafka/server/share/SharePartitionTest.java 
b/core/src/test/java/kafka/server/share/SharePartitionTest.java
index 570e09115ab..4d7be150afa 100644
--- a/core/src/test/java/kafka/server/share/SharePartitionTest.java
+++ b/core/src/test/java/kafka/server/share/SharePartitionTest.java
@@ -2793,6 +2793,7 @@ public class SharePartitionTest {
         ReplicaManager replicaManager = Mockito.mock(ReplicaManager.class);
         SharePartition sharePartition = SharePartitionBuilder.builder()
             .withMetadataProvider(new 
ReplicaManagerPartitionMetadataProvider(replicaManager))
+            
.withDelayedRequestNotifier(replicaManager::completeDelayedShareFetchRequest)
             .withState(SharePartitionState.ACTIVE)
             .build();
 
diff --git a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala 
b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
index 6c2aa46c3d3..d05ea995e5e 100644
--- a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
+++ b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
@@ -47,8 +47,8 @@ import 
org.apache.kafka.common.replica.ClientMetadata.DefaultClientMetadata
 import org.apache.kafka.common.replica.ReplicaView.DefaultReplicaView
 import org.apache.kafka.common.replica.{ClientMetadata, PartitionView, 
ReplicaSelector, ReplicaView}
 import org.apache.kafka.common.requests.FetchRequest.PartitionData
-import org.apache.kafka.server.share.LogReader;
-import org.apache.kafka.server.share.PartitionMetadataProvider;
+import org.apache.kafka.server.share.LogReader
+import org.apache.kafka.server.share.PartitionMetadataProvider
 import org.apache.kafka.common.requests.ProduceResponse.PartitionResponse
 import org.apache.kafka.common.requests._
 import org.apache.kafka.common.security.auth.KafkaPrincipal