Skip to content

Commit f62776c

Browse files
committed
support produce version 12
1 parent 55178c4 commit f62776c

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

Diff for: proxy/processor_default.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,8 @@ func (handler *DefaultRequestHandler) mustReply(requestKeyVersion *protocol.Requ
158158
if err != nil {
159159
return false, nil, err
160160
}
161-
162-
case 3, 4, 5, 6, 7, 8, 9, 10, 11:
161+
default:
162+
// case 3, 4, 5, 6, 7, 8, 9, 10, 11, 12:
163163
// CorrelationID + ClientID
164164
if err = acksReader.ReadAndDiscardHeaderV1Part(reader); err != nil {
165165
return false, nil, err
@@ -169,8 +169,6 @@ func (handler *DefaultRequestHandler) mustReply(requestKeyVersion *protocol.Requ
169169
if err != nil {
170170
return false, nil, err
171171
}
172-
default:
173-
return false, nil, fmt.Errorf("produce version %d is not supported", requestKeyVersion.ApiVersion)
174172
}
175173
return acks != 0, bufferRead.Bytes(), nil
176174
}

0 commit comments

Comments
 (0)