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 af6e262078d7a..4ca71bb626a06 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 @@ boolean joinGroupIfNeeded(final Timer timer) { } } 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 ||