MINOR: Do not print log4j for memberId required
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 Boyang Chen
@@ -465,7 +465,13 @@ public abstract class AbstractCoordinator implements Closeable {
}
} else {
final RuntimeException exception = future.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 ||
