You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by js...@apache.org on 2025/04/09 22:55:21 UTC

(kafka) 03/03: KAFKA-18991; Missing change for cherry-pick

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

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

commit 988da9fc8160051e13516caa0ca45dc3c3404768
Author: José Armando García Sancio <js...@gmail.com>
AuthorDate: Wed Apr 9 12:52:15 2025 -0400

    KAFKA-18991; Missing change for cherry-pick
---
 core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala b/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
index dcbe177b3ac..b77e25a533b 100644
--- a/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
+++ b/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
@@ -32,6 +32,7 @@ import org.junit.jupiter.api.Assumptions.assumeTrue
 import org.junit.jupiter.api.{BeforeEach, Test}
 import kafka.server.FetcherThreadTestUtils.{initialFetchState, mkBatch}
 
+import java.util.Optional;
 import java.util.concurrent.atomic.AtomicInteger
 import scala.collection.mutable.ArrayBuffer
 import scala.collection.{Map, Set}
@@ -1223,4 +1224,4 @@ class AbstractFetcherThreadTest {
     fetcher.processFetchRequest(partitionData, fetchRequestOpt)
     assertEquals(0, replicaState.logEndOffset, "FetchResponse should be ignored when leader epoch does not match")
   }
-}
\ No newline at end of file
+}