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 eeeef35d396b4..da5a40f443320 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 @@ -243,7 +243,7 @@ protected synchronized boolean ensureCoordinatorReady(final Timer timer) { if (future.failed()) { if (future.isRetriable()) { - log.debug("Coordinator discovery failed, refreshing metadata"); + log.debug("Coordinator discovery failed, refreshing metadata", future.exception()); client.awaitMetadataUpdate(timer); } else throw future.exception();