[kafka] branch 2.7 updated: MINOR: Do not print log4j for memberId required (#9667)

[bbejeck]

This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.7 by this push:
     new bd9c925  MINOR: Do not print log4j for memberId required (#9667)
bd9c925 is described below

commit bd9c925db693d77c8171862514ee2b9efb6a7176
Author: Guozhang Wang <wangg...@gmail.com>
AuthorDate: Fri Dec 4 14:02:17 2020 -0800

    MINOR: Do not print log4j for memberId required (#9667)
    
    For MemberIdRequiredException, we would not print the exception at INFO 
with a full exception message since it may introduce more confusion that 
clearance.
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>, Boyang Chen 
<boy...@confluent.io>
---
 .../kafka/clients/consumer/internals/AbstractCoordinator.java     | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
index af6e262..4ca71bb 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
@@ -465,7 +465,13 @@ public abstract class AbstractCoordinator implements 
Closeable {
                 }
             } else {
                 final RuntimeException exception = future.exception();
-                log.info("Rebalance failed.", exception);
+
+                // we do not need to log error for memberId required,
+                // since it is not really an error and is transient
+                if (!(exception instanceof MemberIdRequiredException)) {
+                    log.info("Rebalance failed.", exception);
+                }
+
                 resetJoinGroupFuture();
                 if (exception instanceof UnknownMemberIdException ||
                     exception instanceof RebalanceInProgressException ||