From d5273b502df6f6def43be1629bb51e39b2a47261 Mon Sep 17 00:00:00 2001 From: Pierre-Yves Ritschard Date: Sat, 14 Jan 2012 11:08:41 +0100 Subject: [PATCH] Fix KAFKA-247 by bumping fetch.size The rationale here is to bump fetch.size a bit beyond the default produce size. Coincidentally, it seems that the MaxFetchSize property is used nowhere throughout the code. --- .../main/scala/kafka/consumer/ConsumerConfig.scala | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala index 31196ff..c7f0abf 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala @@ -24,7 +24,7 @@ import kafka.common.InvalidConfigException 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 -- 1.7.5.4