kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject git commit: KAFKA-995 Ensure that replica fetch size is > max message size on server.
Date Sat, 03 Aug 2013 16:54:44 GMT
Updated Branches:
  refs/heads/trunk d285e263b -> bdb2fdc64


KAFKA-995 Ensure that replica fetch size is > max message size on server.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bdb2fdc6
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bdb2fdc6
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bdb2fdc6

Branch: refs/heads/trunk
Commit: bdb2fdc6460c48189b487e1e8a75c344e32aa222
Parents: d285e26
Author: Jay Kreps <jay.kreps@gmail.com>
Authored: Sat Aug 3 09:46:50 2013 -0700
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Sat Aug 3 09:46:50 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/KafkaConfig.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/bdb2fdc6/core/src/main/scala/kafka/server/KafkaConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala
index 21f4199..f7d8b03 100644
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -186,7 +186,7 @@ class KafkaConfig private (val props: VerifiableProperties) extends ZKConfig(pro
   val replicaSocketReceiveBufferBytes = props.getInt("replica.socket.receive.buffer.bytes",
ConsumerConfig.SocketBufferSize)
 
   /* the number of byes of messages to attempt to fetch */
-  val replicaFetchMaxBytes = props.getInt("replica.fetch.max.bytes", ConsumerConfig.FetchSize)
+  val replicaFetchMaxBytes = props.getIntInRange("replica.fetch.max.bytes", ConsumerConfig.FetchSize,
(messageMaxBytes, Int.MaxValue))
 
   /* max wait time for each fetcher request issued by follower replicas*/
   val replicaFetchWaitMaxMs = props.getInt("replica.fetch.wait.max.ms", 500)


Mime
View raw message