support produce version 12

everesio · everesio · commit 49670cc15a82 · 2025-03-24T01:05:41.000+01:00
diff --git a/proxy/processor_default.go b/proxy/processor_default.go
@@ -159,7 +159,7 @@ func (handler *DefaultRequestHandler) mustReply(requestKeyVersion *protocol.Requ
 				return false, nil, err
 			}
 
-		case 3, 4, 5, 6, 7, 8, 9, 10, 11:
+		case 3, 4, 5, 6, 7, 8, 9, 10, 11, 12:
 			// CorrelationID + ClientID
 			if err = acksReader.ReadAndDiscardHeaderV1Part(reader); err != nil {
 				return false, nil, err

Original file line number	Diff line number	Diff line change
`@@ -159,7 +159,7 @@ func (handler DefaultRequestHandler) mustReply(requestKeyVersion protocol.Requ`
`159`	`159`	`return false, nil, err`
`160`	`160`	`}`
`161`	`161`
`162`		`- case 3, 4, 5, 6, 7, 8, 9, 10, 11:`
	`162`	`+ case 3, 4, 5, 6, 7, 8, 9, 10, 11, 12:`
`163`	`163`	`// CorrelationID + ClientID`
`164`	`164`	`if err = acksReader.ReadAndDiscardHeaderV1Part(reader); err != nil {`
`165`	`165`	`return false, nil, err`