Blocker Description
The config `sasl.mechanism.controller.protocol` from KIP-631 is not implemented. Furthermore, `KafkaRaftManager` is using inter-broker security information when it connects to the Raft controller quorum. KafkaRaftClient should use the first entry in `controller.listener.names` to determine the listener name; that listener name's mapped value in the `listener.security.protocol.map` (if such a mapping exists, otherwise the listener name itself) for the security protocol; and the value of `sasl.mechanism.controller.protocol` for the SASL mechanism. Finally, `RaftControllerNodeProvider` needs to use the value of `sasl.mechanism.controller.protocol` instead of the inter-broker sasl mechanism (it currently determines the listener name and security protocol correctly)
Attachments
Issue Links
- links to