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 9c747ec611f50..7ba9b7acf5e78 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 static AbstractResponse parseResponse(ApiKeys apiKey, Struct struct, shor 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: