You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/04/25 17:22:39 UTC
git commit: kafka-1424;
transient unit test failure in testSendWithDeadBroker; patched by Jun Rao;
reviewed by Timothy Chen
Repository: kafka
Updated Branches:
refs/heads/trunk 3ebbaaea9 -> e69c61327
kafka-1424; transient unit test failure in testSendWithDeadBroker; patched by Jun Rao; reviewed by Timothy Chen
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e69c6132
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e69c6132
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e69c6132
Branch: refs/heads/trunk
Commit: e69c613274250bca2bd40a2b3523b55c8231978b
Parents: 3ebbaae
Author: Jun Rao <ju...@gmail.com>
Authored: Fri Apr 25 08:22:34 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Fri Apr 25 08:22:34 2014 -0700
----------------------------------------------------------------------
core/src/test/scala/unit/kafka/producer/ProducerTest.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/e69c6132/core/src/test/scala/unit/kafka/producer/ProducerTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/producer/ProducerTest.scala b/core/src/test/scala/unit/kafka/producer/ProducerTest.scala
index dc6a5ea..7877da8 100644
--- a/core/src/test/scala/unit/kafka/producer/ProducerTest.scala
+++ b/core/src/test/scala/unit/kafka/producer/ProducerTest.scala
@@ -234,6 +234,7 @@ class ProducerTest extends JUnit3Suite with ZooKeeperTestHarness with Logging{
// restart server 1
server1.startup()
TestUtils.waitUntilLeaderIsElectedOrChanged(zkClient, topic, 0)
+ TestUtils.waitUntilMetadataIsPropagated(servers, topic, 0)
try {
// cross check if broker 1 got the messages