From 5e174e3feabe03c14a6dca451fdf0967285069ff Mon Sep 17 00:00:00 2001 From: lvfangmin Date: Mon, 27 Apr 2015 22:40:35 +0800 Subject: [PATCH] Patch for KAFKA-2055: ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure --- core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala index 5c4cca6..a17f553 100644 --- a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala +++ b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala @@ -106,6 +106,9 @@ class ConsumerBounceTest extends IntegrationTestHarness with Logging { consumer.subscribe(tp) consumer.seek(tp, 0) + // sleep for a while to guarantee followers have synced the last HW with leader + Thread.sleep(1000) + val scheduler = new BounceBrokerScheduler(numIters) scheduler.start() -- 2.3.2 (Apple Git-55)