From 35448e74108b68d7cd4842dcaf3128d1004bda57 Mon Sep 17 00:00:00 2001 From: John Roesler Date: Thu, 28 May 2020 13:23:55 -0500 Subject: [PATCH] MINOR: Log the reason for coordinator discovery failure --- .../kafka/clients/consumer/internals/AbstractCoordinator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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();