You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/08/26 18:12:29 UTC
kafka git commit: MINOR: Include request header in exception when
correlation of request/response fails
Repository: kafka
Updated Branches:
refs/heads/trunk b4ddd021b -> d4c379832
MINOR: Include request header in exception when correlation of request/response fails
Author: Ismael Juma <is...@juma.me.uk>
Reviewers: Guozhang Wang <wa...@gmail.com>
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 <is...@juma.me.uk>
Authored: Fri Aug 26 11:12:25 2016 -0700
Committer: Guozhang Wang <wa...@gmail.com>
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);
}
/**