MINOR: Log error when storing assignment fails
Reviewers: Jason Gustafson
@@ -614,7 +614,7 @@ class GroupCoordinator(val brokerId: Int,
if (group.is(CompletingRebalance) && generationId == group.generationId) {
if (error != Errors.NONE) {
resetAndPropagateAssignmentError(group, error)
- maybePrepareRebalance(group, s"Error when storing group assignment during SyncGroup (member: $memberId)")
+ maybePrepareRebalance(group, s"Error $error when storing group assignment during SyncGroup (member: $memberId)")
} else {
setAndPropagateAssignment(group, assignment)
group.transitionTo(Stable)
