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))
|