Repository: kafka Updated Branches: refs/heads/trunk 5a9b12eb5 -> 394eda510
KAFKA-2877: handle request timeout in sync group Author: Jason Gustafson <[email protected]> Reviewers: Ben Stopford, Guozhang Wang Closes #582 from hachikuji/KAFKA-2877 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/394eda51 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/394eda51 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/394eda51 Branch: refs/heads/trunk Commit: 394eda510dfc1af5c614fa88ee96c7cf2c098fd0 Parents: 5a9b12e 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:23 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/394eda51/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))
