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

jgus 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 42272f0  MINOR: Propage version correctly in `FetchSnapshotRequest` 
constructor (#9804)
42272f0 is described below

commit 42272f0a37c2f4df1d629617d299a4d7e97dcedc
Author: Jason Gustafson <[email protected]>
AuthorDate: Thu Dec 31 10:26:45 2020 -0800

    MINOR: Propage version correctly in `FetchSnapshotRequest` constructor 
(#9804)
    
    Pass through the version to the super constructor in `FetchSnapshotRequest`.
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 .../java/org/apache/kafka/common/requests/FetchSnapshotRequest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotRequest.java
 
b/clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotRequest.java
index 30952ac..b50c193 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotRequest.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotRequest.java
@@ -32,7 +32,7 @@ final public class FetchSnapshotRequest extends 
AbstractRequest {
     public final FetchSnapshotRequestData data;
 
     public FetchSnapshotRequest(FetchSnapshotRequestData data, short version) {
-        super(ApiKeys.FETCH_SNAPSHOT, (short) 
(FetchSnapshotRequestData.SCHEMAS.length - 1));
+        super(ApiKeys.FETCH_SNAPSHOT, version);
         this.data = data;
     }
 

Reply via email to