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 <[email protected]> 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 +}
