Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id BF560D976 for ; Mon, 21 Jan 2013 03:39:28 +0000 (UTC) Received: (qmail 7549 invoked by uid 500); 21 Jan 2013 03:39:28 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 7427 invoked by uid 500); 21 Jan 2013 03:39:24 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 7369 invoked by uid 99); 21 Jan 2013 03:39:22 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 Jan 2013 03:39:22 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id A3A208221ED; Mon, 21 Jan 2013 03:39:21 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: joestein@apache.org To: commits@kafka.apache.org X-Mailer: ASF-Git Admin Mailer Subject: 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 Message-Id: <20130121033921.A3A208221ED@tyr.zones.apache.org> Date: Mon, 21 Jan 2013 03:39:21 +0000 (UTC) Updated Branches: refs/heads/0.8 ecd1f19f5 -> 1e011bf42 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/0.8 Commit: 1e011bf42efce996a553d6c0a2d7e51b45622b6b Parents: ecd1f19 Author: Joe Stein Authored: Sun Jan 20 22:37:56 2013 -0500 Committer: Joe Stein 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)