According to the protocol document, brokers are supposed to reject messages containing a higher API version than they understand. This is important because the encoded response does not contain the API version used.
Jocko declares to the client which API versions it supports (defined in protocol/api_versions.go). But I can't see whether it enforces this in incoming requests, and I think it should. It would just be a question of checking the received API version (second field in Request Header) against the min/max values in protocol.APIVersions
According to the protocol document, brokers are supposed to reject messages containing a higher API version than they understand. This is important because the encoded response does not contain the API version used.
Jocko declares to the client which API versions it supports (defined in
protocol/api_versions.go). But I can't see whether it enforces this in incoming requests, and I think it should. It would just be a question of checking the received API version (second field in Request Header) against the min/max values in protocol.APIVersions