[2/4] git commit: KAFKA-709 change in default blocking tripped test checking queue is full so updated test in case someone changes the new default to something else

[ju...@apache.org]

KAFKA-709 change in default blocking tripped test checking queue is full so updated test in case someone changes the new default to something else


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

Branch: refs/heads/trunk
Commit: 1e011bf42efce996a553d6c0a2d7e51b45622b6b
Parents: ecd1f19
Author: Joe Stein <jo...@Josephs-MacBook-Pro.local>
Authored: Sun Jan 20 22:37:56 2013 -0500
Committer: Joe Stein <jo...@Josephs-MacBook-Pro.local>
Committed: Sun Jan 20 22:37:56 2013 -0500

----------------------------------------------------------------------
 .../unit/kafka/producer/AsyncProducerTest.scala    |    1 +
 1 files changed, 1 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1e011bf4/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala b/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
index beb63a4..fb0666f 100644
--- a/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
+++ b/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
@@ -65,6 +65,7 @@ class AsyncProducerTest extends JUnit3Suite {
     props.put("producer.type", "async")
     props.put("queue.buffering.max.messages", "10")
     props.put("batch.num.messages", "1")
+    props.put("queue.enqueue.timeout.ms", "0")
 
     val config = new ProducerConfig(props)
     val produceData = getProduceData(12)