FrankYang0529 commented on code in PR #17411:
URL: https://github.com/apache/kafka/pull/17411#discussion_r1800893278


##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java:
##########
@@ -378,11 +378,17 @@ private void onErrorResponse(final R response, final long 
currentTimeMs) {
             case INVALID_REQUEST:
             case GROUP_MAX_SIZE_REACHED:
             case UNSUPPORTED_ASSIGNOR:
-            case UNSUPPORTED_VERSION:
                 logger.error("{} failed due to {}: {}", 
heartbeatRequestName(), error, errorMessage);
                 handleFatalFailure(error.exception(errorMessage));
                 break;
 
+            case UNSUPPORTED_VERSION:
+                message = "The cluster doesn't yet support the new consumer 
group protocol." +
+                        " Set group.protocol=classic to revert to the classic 
protocol until the cluster is upgraded.";
+                logger.error("{} failed due to {}: {}", 
heartbeatRequestName(), error, message);

Review Comment:
   Yes, we give user message in the exception (the assertion in test case), so 
we don't need to log it here. Thanks.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to