You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2026/06/01 16:03:02 UTC
(kafka) branch trunk updated: KAFKA-20610: Minor - correcting test and scala imports (4/N) (#22438)
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 <ap...@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 <ma...@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