From 057a1f1539143b4d12a899267ccd8a223a021d26 Mon Sep 17 00:00:00 2001 From: lvfangmin Date: Fri, 24 Jul 2015 20:11:31 +0100 Subject: [PATCH] KAFKA-2055; Fix transient ConsumerBounceTest.testSeekAndCommitWithBrokerFailures failure; --- core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala index d8eee52..93f9468 100644 --- a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala +++ b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala @@ -104,6 +104,11 @@ class ConsumerBounceTest extends IntegrationTestHarness with Logging { consumer.subscribe(tp) consumer.seek(tp, 0) + // wait until all the followers have synced the last HW with leader + TestUtils.waitUntilTrue(() => servers.forall(server => + server.replicaManager.getReplica(tp.topic(), tp.partition()).get.highWatermark.messageOffset == numRecords + ), "Failed to update high watermark for followers after timeout") + val scheduler = new BounceBrokerScheduler(numIters) scheduler.start() -- 1.9.5