From 5c24cd6db4cb391725d60feb15a07dadbcaefc34 Mon Sep 17 00:00:00 2001 From: mgharat Date: Fri, 3 Oct 2014 15:53:19 -0700 Subject: [PATCH] Updated the default settings for MaxRebalanceRetries and RebalanceBackOffMs --- core/src/main/scala/kafka/consumer/ConsumerConfig.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala index 9ebbee6..49ead65 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala @@ -33,7 +33,7 @@ object ConsumerConfig extends Config { val AutoCommit = true val AutoCommitInterval = 60 * 1000 val MaxQueuedChunks = 2 - val MaxRebalanceRetries = 4 + val MaxRebalanceRetries = 12 val AutoOffsetReset = OffsetRequest.LargestTimeString val ConsumerTimeoutMs = -1 val MinFetchBytes = 1 @@ -45,6 +45,7 @@ object ConsumerConfig extends Config { val OffsetsChannelSocketTimeoutMs = 10000 val OffsetsCommitMaxRetries = 5 val OffsetsStorage = "zookeeper" + val RebalanceBackOffMs = 30000 val MirrorTopicsWhitelistProp = "mirror.topics.whitelist" val MirrorTopicsBlacklistProp = "mirror.topics.blacklist" @@ -135,7 +136,7 @@ class ConsumerConfig private (val props: VerifiableProperties) extends ZKConfig( val fetchWaitMaxMs = props.getInt("fetch.wait.max.ms", MaxFetchWaitMs) /** backoff time between retries during rebalance */ - val rebalanceBackoffMs = props.getInt("rebalance.backoff.ms", zkSyncTimeMs) + val rebalanceBackoffMs = props.getInt("rebalance.backoff.ms", RebalanceBackOffMs) /** backoff time to refresh the leader of a partition after it loses the current leader */ val refreshLeaderBackoffMs = props.getInt("refresh.leader.backoff.ms", RefreshMetadataBackoffMs) -- 1.9.3 (Apple Git-50)