kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-709 Default queue.enqueue.timeout.ms to -1; reviewed by Jay Kreps
Date Fri, 18 Jan 2013 05:31:11 GMT
Updated Branches:
  refs/heads/0.8 214a0af46 -> ecd1f19f5


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/0.8
Commit: ecd1f19f5aea2d2907d1a5594080062cb5c945f1
Parents: 214a0af
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Thu Jan 17 21:31:06 2013 -0800
Committer: Neha Narkhede <neha.narkhede@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)


Mime
View raw message