From 1f5bc11cc0e94110e9cb673cacc63c02bb23c279 Mon Sep 17 00:00:00 2001 From: Bryan Baugher Date: Mon, 11 Sep 2017 16:57:37 +0100 Subject: [PATCH] MINOR: Implement toString for NetworkClient#InFlightRequest Author: Bryan Baugher Reviewers: Ismael Juma Closes #3805 from bbaugher/inFlightRequest_toString --- .../org/apache/kafka/clients/NetworkClient.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java index 31b8edb91eb..4a20a3f3b8a 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -974,6 +974,19 @@ public class NetworkClient implements KafkaClient { public ClientResponse disconnected(long timeMs) { return new ClientResponse(header, callback, destination, createdTimeMs, timeMs, true, null, null); } + + @Override + public String toString() { + return "InFlightRequest(header=" + header + + ", destination=" + destination + + ", expectResponse=" + expectResponse + + ", createdTimeMs=" + createdTimeMs + + ", sendTimeMs=" + sendTimeMs + + ", isInternalRequest=" + isInternalRequest + + ", request=" + request + + ", callback=" + callback + + ", send=" + send + ")"; + } } public boolean discoverBrokerVersions() {