You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2012/12/18 00:06:05 UTC
git commit: trivial change to increase default offset commit interval
to reduce ZK load
Updated Branches:
refs/heads/0.8 792b071cc -> af83dfbe0
trivial change to increase default offset commit interval to reduce ZK load
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/af83dfbe
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/af83dfbe
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/af83dfbe
Branch: refs/heads/0.8
Commit: af83dfbe0c092eea37e9b1b840870386bb612db8
Parents: 792b071
Author: Jun Rao <jr...@jrao-ld.linkedin.biz>
Authored: Mon Dec 17 14:56:13 2012 -0800
Committer: Jun Rao <jr...@jrao-ld.linkedin.biz>
Committed: Mon Dec 17 14:56:13 2012 -0800
----------------------------------------------------------------------
.../main/scala/kafka/consumer/ConsumerConfig.scala | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/af83dfbe/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
index 50a2cd4..b379c9d 100644
--- a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
+++ b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala
@@ -29,7 +29,7 @@ object ConsumerConfig extends Config {
val MaxFetchSize = 10*FetchSize
val DefaultFetcherBackoffMs = 1000
val AutoCommit = true
- val AutoCommitInterval = 10 * 1000
+ val AutoCommitInterval = 60 * 1000
val MaxQueuedChunks = 10
val MaxRebalanceRetries = 4
val AutoOffsetReset = OffsetRequest.SmallestTimeString