Repository: kafka Updated Branches: refs/heads/0.10.0 9b3e9f3df -> ca45bd031
MINOR: Include request header in exception when correlation of request/response fails Author: Ismael Juma <[email protected]> Reviewers: Guozhang Wang <[email protected]> Closes #1793 from ijuma/include-request-header-if-request-correlation-fails (cherry picked from commit d4c379832b525d1a9c20c5cb84f0e586b9d977e0) Signed-off-by: Guozhang Wang <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ca45bd03 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ca45bd03 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ca45bd03 Branch: refs/heads/0.10.0 Commit: ca45bd0317c024b3ec06fc235cf6a0377733c6c2 Parents: 9b3e9f3 Author: Ismael Juma <[email protected]> Authored: Fri Aug 26 11:12:25 2016 -0700 Committer: Guozhang Wang <[email protected]> Committed: Fri Aug 26 11:12:34 2016 -0700 ---------------------------------------------------------------------- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ca45bd03/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 b134631..bd54a29 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -484,7 +484,7 @@ public class NetworkClient implements KafkaClient { private static void correlate(RequestHeader requestHeader, ResponseHeader responseHeader) { if (requestHeader.correlationId() != responseHeader.correlationId()) throw new IllegalStateException("Correlation id for response (" + responseHeader.correlationId() - + ") does not match request (" + requestHeader.correlationId() + ")"); + + ") does not match request (" + requestHeader.correlationId() + "), request header: " + requestHeader); } /**
