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
+}