kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2877: handle request timeout in sync group
Date Wed, 25 Nov 2015 00:17:38 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 10b3e6a5e -> 701ac0022


KAFKA-2877: handle request timeout in sync group

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ben Stopford, Guozhang Wang

Closes #582 from hachikuji/KAFKA-2877

(cherry picked from commit 394eda510dfc1af5c614fa88ee96c7cf2c098fd0)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/701ac002
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/701ac002
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/701ac002

Branch: refs/heads/0.9.0
Commit: 701ac0022e3bc0530f4411c3a4b0c66783f9bdce
Parents: 10b3e6a
Author: Jason Gustafson <jason@confluent.io>
Authored: Tue Nov 24 16:17:23 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Nov 24 16:17:34 2015 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/701ac002/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala b/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
index a63f226..167267f 100644
--- a/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
+++ b/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
@@ -199,6 +199,8 @@ class GroupMetadataManager(val brokerId: Int,
           Errors.GROUP_COORDINATOR_NOT_AVAILABLE.code
         } else if (status.error == ErrorMapping.NotLeaderForPartitionCode) {
           Errors.NOT_COORDINATOR_FOR_GROUP.code
+        } else if (status.error == ErrorMapping.RequestTimedOutCode) {
+          Errors.REBALANCE_IN_PROGRESS.code
         } else if (status.error == ErrorMapping.MessageSizeTooLargeCode
           || status.error == ErrorMapping.MessageSetSizeTooLargeCode
           || status.error == ErrorMapping.InvalidFetchSizeCode) {
@@ -208,7 +210,6 @@ class GroupMetadataManager(val brokerId: Int,
 
           Errors.UNKNOWN.code
         } else {
-
           error("Appending metadata message for group %s generation %d failed due to unexpected
error: %s"
             .format(group.groupId, generationId, status.error))
 


Mime
View raw message