Repository: kafka Updated Branches: refs/heads/0.9.0 10b3e6a5e -> 701ac0022
KAFKA-2877: handle request timeout in sync group Author: Jason Gustafson <[email protected]> Reviewers: Ben Stopford, Guozhang Wang Closes #582 from hachikuji/KAFKA-2877 (cherry picked from commit 394eda510dfc1af5c614fa88ee96c7cf2c098fd0) Signed-off-by: Guozhang Wang <[email protected]> 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 <[email protected]> Authored: Tue Nov 24 16:17:23 2015 -0800 Committer: Guozhang Wang <[email protected]> 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))
