kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Implement toString for NetworkClient#InFlightRequest
Date Mon, 11 Sep 2017 22:48:10 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk d6fabb011 -> 1f5bc11cc


MINOR: Implement toString for NetworkClient#InFlightRequest

Author: Bryan Baugher <bryan.baugher@cerner.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #3805 from bbaugher/inFlightRequest_toString


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1f5bc11c
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1f5bc11c
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1f5bc11c

Branch: refs/heads/trunk
Commit: 1f5bc11cc0e94110e9cb673cacc63c02bb23c279
Parents: d6fabb0
Author: Bryan Baugher <bryan.baugher@cerner.com>
Authored: Mon Sep 11 16:57:37 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Mon Sep 11 23:47:00 2017 +0100

----------------------------------------------------------------------
 .../java/org/apache/kafka/clients/NetworkClient.java   | 13 +++++++++++++
 1 file changed, 13 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1f5bc11c/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
----------------------------------------------------------------------
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 31b8edb..4a20a3f 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() {


Mime
View raw message