[kafka] branch trunk updated: MINOR: correctly parse version OffsetCommitResponse version < 3

[gw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gwenshap pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 8308829  MINOR: correctly parse version OffsetCommitResponse version < 3
8308829 is described below

commit 8308829e46fcc4903b9faa3d2dcdf10f56f262fe
Author: Lucas Bradstreet <lu...@confluent.io>
AuthorDate: Tue May 7 20:25:37 2019 -0700

    MINOR: correctly parse version OffsetCommitResponse version < 3
    
    KAFKA-7903: automatically generate OffsetCommitRequest (#6583) introduced a change that cause consumer breakage when OffsetCommitResponse versions < 3 are parsed, as they do not include a throttle_time_ms field. This PR fixes the parsing by supplying the correct version to the OffsetCommitResponse constructor in AbstractResponse.parseResponse.
    
    I have tested this change against many of the compatibility system tests, and it has fixed all the failures that I have tested thus far.
    
    Author: Lucas Bradstreet <lu...@confluent.io>
    
    Reviewers: Gwen Shapira, Boyang Chen
    
    Closes #6698 from lbradstreet/offset-commit-response-throttle-field
---
 .../main/java/org/apache/kafka/common/requests/AbstractResponse.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java b/clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
index 9c747ec..7ba9b7a 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
@@ -79,7 +79,7 @@ public abstract class AbstractResponse extends AbstractRequestResponse {
             case METADATA:
                 return new MetadataResponse(struct, version);
             case OFFSET_COMMIT:
-                return new OffsetCommitResponse(struct);
+                return new OffsetCommitResponse(struct, version);
             case OFFSET_FETCH:
                 return new OffsetFetchResponse(struct);
             case FIND_COORDINATOR: