kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2055; Fix transient ConsumerBounceTest.testSeekAndCommitWithBrokerFailure failure.
Date Tue, 04 Aug 2015 18:28:14 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3c0963084 -> 4b400afce


KAFKA-2055; Fix transient ConsumerBounceTest.testSeekAndCommitWithBrokerFailure failure.

…kerFailures failure;

Author: lvfangmin <lvfangmin@gmail.com>

Reviewers: Guozhang

Closes #98 from lvfangmin/KAFKA-2055 and squashes the following commits:

057a1f1 [lvfangmin] KAFKA-2055; Fix transient ConsumerBounceTest.testSeekAndCommitWithBrokerFailures
failure;


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4b400afc
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/4b400afc
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/4b400afc

Branch: refs/heads/trunk
Commit: 4b400afceadcbe74e3ecbfeb7c3066fd436da192
Parents: 3c09630
Author: lvfangmin <lvfangmin@gmail.com>
Authored: Tue Aug 4 11:29:10 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Aug 4 11:29:10 2015 -0700

----------------------------------------------------------------------
 .../test/scala/integration/kafka/api/ConsumerBounceTest.scala   | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/4b400afc/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala
----------------------------------------------------------------------
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()
 


Mime
View raw message