KAFKA-13228: ApiVersionRequest is not properly handled in KRaft co-resident mode#11261
KAFKA-13228: ApiVersionRequest is not properly handled in KRaft co-resident mode#11261dengziming wants to merge 2 commits intoapache:trunkfrom
Conversation
631b0de to
f38c1e1
Compare
There was a problem hiding this comment.
Hello @hachikuji , you changed NodeApiVersions.create() to account for ApiKeys.zkBrokerApis() in #10066 , but this is not right if the controller is KRaft mode, I added a controllerBrokerType in BrokerToControllerChannelManagerImpl to solve this problem. Also cc @abbccdda
There was a problem hiding this comment.
These overrides are unnecessary if we use ClusterTestExtensions
There was a problem hiding this comment.
This will result in NPE
f38c1e1 to
678ccca
Compare
f6a73ea to
ce1c2a0
Compare
|
I also found that we do not support |
|
Hello @mumrah , are you interested in reviewing this, currently, APiVersionRequest is not properly handled in KRaft server and will have a bad effect on KIP-778. |
|
Hello @mumrah , are you interested in reviewing this? currently, APiVersionRequest is not properly handled in KRaft server and will have a bad effect on KIP-778. |
|
Was this fixed some other way? |
|
Thanks! |
More detailed description of your change
When I described quorum in Kraft mode I got
org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support DESCRIBE_QUORUM.This happens because we only concerns
ApiKeys.zkBrokerApis()when we callNodeApiVersions.create(), we should useApiKeys.controllerApiVersionswhen in Kraft mode.Summary of testing strategy (including rationale)
After this change, the DESCRIBE_QUORUM request was property handled and got a correct response: