kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1242696 - /incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
Date Fri, 10 Feb 2012 06:52:37 GMT
Author: junrao
Date: Fri Feb 10 06:52:37 2012
New Revision: 1242696

URL: http://svn.apache.org/viewvc?rev=1242696&view=rev
Log:
trivial change to reduce default fetcher queue size

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala?rev=1242696&r1=1242695&r2=1242696&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala Fri Feb
10 06:52:37 2012
@@ -29,7 +29,7 @@ object ConsumerConfig {
   val DefaultFetcherBackoffMs = 1000
   val AutoCommit = true
   val AutoCommitInterval = 10 * 1000
-  val MaxQueuedChunks = 100
+  val MaxQueuedChunks = 10
   val MaxRebalanceRetries = 4
   val AutoOffsetReset = OffsetRequest.SmallestTimeString
   val ConsumerTimeoutMs = -1



Mime
View raw message