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 <[email protected]> Reviewers: Ismael Juma <[email protected]>, Jason Gustafson <[email protected]> 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 <[email protected]> Authored: Mon May 15 11:15:22 2017 -0700 Committer: Jason Gustafson <[email protected]> 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)); } }
