MINOR: Fix flaky testFollowerCompleteDelayedFetchesOnReplication (#14616)

Reviewers: Mickael Maison <mickael.maison@gmail.com>
11 months ago · 03ea24aa1d
1 changed files with 1 additions and 0 deletions
--- 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 {
				@@ -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()