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 2013/01/21 05:54:12 UTC
[1/4] git commit: KAFKA-709 Default queue.enqueue.timeout.ms to -1;
reviewed by Jay Kreps
KAFKA-709 Default queue.enqueue.timeout.ms to -1; reviewed by Jay Kreps
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ecd1f19f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ecd1f19f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ecd1f19f
Branch: refs/heads/trunk
Commit: ecd1f19f5aea2d2907d1a5594080062cb5c945f1
Parents: 214a0af
Author: Neha Narkhede <ne...@gmail.com>
Authored: Thu Jan 17 21:31:06 2013 -0800
Committer: Neha Narkhede <ne...@gmail.com>
Committed: Thu Jan 17 21:31:06 2013 -0800
----------------------------------------------------------------------
.../kafka/producer/async/AsyncProducerConfig.scala | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/ecd1f19f/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala b/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala
index 973fa08..dd39de5 100644
--- a/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala
+++ b/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala
@@ -33,7 +33,7 @@ trait AsyncProducerConfig {
* -ve: enqueue will block indefinitely if the queue is full
* +ve: enqueue will block up to this many milliseconds if the queue is full
*/
- val queueEnqueueTimeoutMs = props.getInt("queue.enqueue.timeout.ms", 0)
+ val queueEnqueueTimeoutMs = props.getInt("queue.enqueue.timeout.ms", -1)
/** the number of messages batched at the producer */
val batchNumMessages = props.getInt("batch.num.messages", 200)