kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1374514 - /incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala
Date Sat, 18 Aug 2012 05:27:00 GMT
Author: junrao
Date: Sat Aug 18 05:26:59 2012
New Revision: 1374514

URL: http://svn.apache.org/viewvc?rev=1374514&view=rev
Log:
failed ERROR messages in LazyInitProducerTest; patched by Yang Ye; reviewed by Jun Rao; kafka-467

Modified:
    incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala

Modified: incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala?rev=1374514&r1=1374513&r2=1374514&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala
(original)
+++ incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala
Sat Aug 18 05:26:59 2012
@@ -132,8 +132,6 @@ class LazyInitProducerTest extends JUnit
       produceList ::= new ProducerData[String, Message](topic, topic, set)
       builder.addFetch(topic, 0, 0, 10000)
     }
-    // wait until leader is elected
-    topics.foreach(topic => TestUtils.waitUntilLeaderIsElectedOrChanged(zkClient, topic,
0, 500))
     producer.send(produceList: _*)
 
     // wait a bit for produced message to be available
@@ -157,9 +155,6 @@ class LazyInitProducerTest extends JUnit
       produceList ::= new ProducerData[String, Message](topic, topic, set)
       builder.addFetch(topic, 0, 0, 10000)
     }
-    // wait until leader is elected
-    topics.foreach(topic => TestUtils.waitUntilLeaderIsElectedOrChanged(zkClient, topic,
0, 1500))
-
     producer.send(produceList: _*)
 
     producer.send(produceList: _*)



Mime
View raw message