[kafka] branch trunk updated: MINOR: Fix flaky testFollowerCompleteDelayedFetchesOnReplication (#14616)

[de...@apache.org]

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

dengziming 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 03ea24aa1da MINOR: Fix flaky testFollowerCompleteDelayedFetchesOnReplication (#14616)
03ea24aa1da is described below

commit 03ea24aa1daa2d372b9e6f158cc354525329ad18
Author: dengziming <de...@gmail.com>
AuthorDate: Wed Oct 25 09:39:29 2023 +0800

    MINOR: Fix flaky testFollowerCompleteDelayedFetchesOnReplication (#14616)
    
    Reviewers: Mickael Maison <mi...@gmail.com>
---
 .../integration/kafka/server/FetchFromFollowerIntegrationTest.scala      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala b/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
index f8c977d429d..dd1ae064f12 100644
--- a/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
+++ b/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
@@ -67,6 +67,7 @@ class FetchFromFollowerIntegrationTest extends BaseFetchRequestTest {
       brokers,
       replicaAssignment = Map(0 -> Seq(leaderBrokerId, followerBrokerId))
     )
+    TestUtils.waitUntilLeaderIsKnown(brokers, new TopicPartition(topic, 0))
     assertTrue(partitionLeaders.values.forall(_ == leaderBrokerId))
 
     val version = ApiKeys.FETCH.latestVersion()