diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java index 82c209ac1283c..3011d56779416 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java @@ -481,9 +481,9 @@ public void consumerRebalanceListenerCallbackCompleted(ConsumerRebalanceListener if (error.isPresent()) { Exception e = error.get(); log.warn( - "The {} method completed with an error ({}); signaling to continue to the next phase of rebalance", - methodName.fullyQualifiedMethodName(), - e.getMessage() + "The {} method failed during rebalance; proceeding to the next phase", + methodName.fullyQualifiedMethodName(), + e ); future.completeExceptionally(e);