kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: AddOffsetsToTxnResponse using incorrect schema in parse
Date Mon, 15 May 2017 18:15:28 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk a511a4702 -> 82e84fabf


HOTFIX: AddOffsetsToTxnResponse using incorrect schema in parse

The parse method was incorrectly referring to `ApiKeys.ADD_PARTITIONS_TO_TXN`

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>, Jason Gustafson <jason@confluent.io>

Closes #3056 from dguy/hotfix-add-offsets-to-txn-response


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/82e84fab
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/82e84fab
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/82e84fab

Branch: refs/heads/trunk
Commit: 82e84fabf87fa5b5e6b4b9fd464edafaa9c5a744
Parents: a511a47
Author: Damian Guy <damian.guy@gmail.com>
Authored: Mon May 15 11:15:22 2017 -0700
Committer: Jason Gustafson <jason@confluent.io>
Committed: Mon May 15 11:15:22 2017 -0700

----------------------------------------------------------------------
 .../org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/82e84fab/clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java
b/clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java
index 8c41ae4..8b3a589 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java
@@ -65,6 +65,6 @@ public class AddOffsetsToTxnResponse extends AbstractResponse {
     }
 
     public static AddOffsetsToTxnResponse parse(ByteBuffer buffer, short version) {
-        return new AddOffsetsToTxnResponse(ApiKeys.ADD_PARTITIONS_TO_TXN.parseResponse(version,
buffer));
+        return new AddOffsetsToTxnResponse(ApiKeys.ADD_OFFSETS_TO_TXN.parseResponse(version,
buffer));
     }
 }


Mime
View raw message