Browse Source

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
pull/3834/head
Bryan Baugher 7 years ago committed by Ismael Juma
parent
commit
1f5bc11cc0
  1. 13
      clients/src/main/java/org/apache/kafka/clients/NetworkClient.java

13
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java

@ -974,6 +974,19 @@ public class NetworkClient implements KafkaClient { @@ -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() {

Loading…
Cancel
Save