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 <[email protected]> Authored: Sat Aug 3 09:46:50 2013 -0700 Committer: Jay Kreps <[email protected]> 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)
