kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1410125 - /incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala
Date Fri, 16 Nov 2012 00:31:58 GMT
Author: junrao
Date: Fri Nov 16 00:31:58 2012
New Revision: 1410125

URL: http://svn.apache.org/viewvc?rev=1410125&view=rev
Log:
trivial fix to make the default value replica.fetch.min.bytes better for replication

Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala?rev=1410125&r1=1410124&r2=1410125&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala (original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala Fri Nov
16 00:31:58 2012
@@ -153,7 +153,7 @@ class KafkaConfig private (val props: Ve
   val replicaMaxWaitTimeMs = props.getInt("replica.fetch.wait.time.ms", 500)
 
   /* minimum bytes expected for each fetch response. If not enough bytes, wait up to replicaMaxWaitTimeMs
*/
-  val replicaMinBytes = props.getInt("replica.fetch.min.bytes", 4096)
+  val replicaMinBytes = props.getInt("replica.fetch.min.bytes", 1)
 
   /* number of fetcher threads used to replicate messages from a source broker.
    * Increasing this value can increase the degree of I/O parallelism in the follower broker.
*/



Mime
View raw message