[kafka] branch trunk updated: MINOR: Log error when storing assignment fails (#12526)

[dajac]

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 <dja...@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)