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;
}