You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2022/08/18 07:37:28 UTC
[kafka] branch trunk updated: MINOR: Log error when storing assignment fails (#12526)
This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 04fce135d3 MINOR: Log error when storing assignment fails (#12526)
04fce135d3 is described below
commit 04fce135d3b89519ac970f3b7252d5a6b62db717
Author: David Jacot <dj...@confluent.io>
AuthorDate: Thu Aug 18 09:37:20 2022 +0200
MINOR: Log error when storing assignment fails (#12526)
Reviewers: Jason Gustafson <ja...@confluent.io>
---
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala b/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
index 6bf337d679..6aff7fbd7b 100644
--- a/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
+++ b/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
@@ -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)