From fd02c8f07fa04b10aa8fa64b3934ce0a439aa037 Mon Sep 17 00:00:00 2001
From: Mickael Maison <mimaison@users.noreply.github.com>
Date: Wed, 2 Sep 2020 18:04:51 +0200
Subject: [PATCH] MINOR: Include call name in TimeoutException (#8050)

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
---
 .../java/org/apache/kafka/clients/admin/KafkaAdminClient.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
index 8507783e84e..6daaca6023b 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
@@ -882,7 +882,7 @@ public class KafkaAdminClient extends AdminClient {
                 Call call = iter.next();
                 int remainingMs = calcTimeoutMsRemainingAsInt(now, call.deadlineMs);
                 if (remainingMs < 0) {
-                    call.fail(now, new TimeoutException(msg));
+                    call.fail(now, new TimeoutException(msg + " Call: " + call.callName));
                     iter.remove();
                     numTimedOut++;
                 } else {