You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/09/11 22:48:10 UTC
kafka git commit: MINOR: Implement toString for
NetworkClient#InFlightRequest
Repository: kafka
Updated Branches:
refs/heads/trunk d6fabb011 -> 1f5bc11cc
MINOR: Implement toString for NetworkClient#InFlightRequest
Author: Bryan Baugher <br...@cerner.com>
Reviewers: Ismael Juma <is...@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 <br...@cerner.com>
Authored: Mon Sep 11 16:57:37 2017 +0100
Committer: Ismael Juma <is...@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() {