You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2017/05/15 18:15:28 UTC
kafka git commit: HOTFIX: AddOffsetsToTxnResponse using incorrect
schema in parse
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 <da...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>, Jason Gustafson <ja...@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 <da...@gmail.com>
Authored: Mon May 15 11:15:22 2017 -0700
Committer: Jason Gustafson <ja...@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));
}
}