kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: trivial change to increase default offset commit interval to reduce ZK load
Date Mon, 17 Dec 2012 23:06:05 GMT
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 <jrao@jrao-ld.linkedin.biz>
Authored: Mon Dec 17 14:56:13 2012 -0800
Committer: Jun Rao <jrao@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


Mime
View raw message