MINOR: Include call name in TimeoutException (#8050)

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
4 years ago · fd02c8f07f
1 changed files with 1 additions and 1 deletions
--- 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 {
				@@ -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 {