add version 7

childe · Oct 17, 2024 · 586bd4b · 586bd4b
1 parent f047fbb
commit 586bd4b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fetch_response.go b/fetch_response.go
@@ -344,7 +344,7 @@ func (streamDecoder *fetchResponseStreamDecoder) decodePartitionResponse(topicNa
 	switch version {
 	case 0:
 		bytesBeforeRecordsLength = 18
-	case 10:
+	case 7, 10:
 		bytesBeforeRecordsLength = 38
 	}
 	buffer, n, err = streamDecoder.read(bytesBeforeRecordsLength)
@@ -424,7 +424,7 @@ func (streamDecoder *fetchResponseStreamDecoder) decodeHeader(version uint16) er
 	case 0:
 		headerLength = 8
 		countOffset = 4
-	case 10:
+	case 7, 10:
 		headerLength = 18
 		countOffset = 14
 	}