Repository: kafka Updated Branches: refs/heads/trunk b4ddd021b -> d4c379832
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 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d4c37983 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d4c37983 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d4c37983 Branch: refs/heads/trunk Commit: d4c379832b525d1a9c20c5cb84f0e586b9d977e0 Parents: b4ddd02 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:25 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/d4c37983/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); } /**
