kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1232500 - /incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
Date Tue, 17 Jan 2012 17:30:38 GMT
Author: junrao
Date: Tue Jan 17 17:30:38 2012
New Revision: 1232500

URL: http://svn.apache.org/viewvc?rev=1232500&view=rev
Log:
max.message.size and fetch.size defaults should be consistent; patched by Pierre-Yves Ritschard;
reviewed by Jun Rao; KAFKA-247

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=1232500&r1=1232499&r2=1232500&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 Tue Jan
17 17:30:38 2012
@@ -24,7 +24,7 @@ import kafka.common.InvalidConfigExcepti
 object ConsumerConfig {
   val SocketTimeout = 30 * 1000
   val SocketBufferSize = 64*1024
-  val FetchSize = 300 * 1024
+  val FetchSize = 1024 * 1024
   val MaxFetchSize = 10*FetchSize
   val DefaultFetcherBackoffMs = 1000
   val AutoCommit = true
@@ -62,9 +62,6 @@ class ConsumerConfig(props: Properties) 
   /** the number of byes of messages to attempt to fetch */
   val fetchSize = Utils.getInt(props, "fetch.size", FetchSize)
   
-  /** the maximum allowable fetch size for a very large message */
-  val maxFetchSize: Int = fetchSize * 10
-  
   /** to avoid repeatedly polling a broker node which has no new data
       we will backoff every time we get an empty set from the broker*/
   val fetcherBackoffMs: Long = Utils.getInt(props, "fetcher.backoff.ms", DefaultFetcherBackoffMs)



Mime
View raw message