[
https://issues.apache.org/jira/browse/KAFKA-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deng Ziming updated KAFKA-15065:
--------------------------------
Issue Type: Bug (was: Improvement)
> ApiVersionRequest is not properly handled in Sasl ControllerServer
> ------------------------------------------------------------------
>
> Key: KAFKA-15065
> URL: https://issues.apache.org/jira/browse/KAFKA-15065
> Project: Kafka
> Issue Type: Bug
> Reporter: Deng Ziming
> Priority: Major
>
> In KAFKA-14291 we add finalizedFeatures in ApiVersionResponse, also change
> the `apiVersionResponse` method to throw exception:
> {code:java}
> override def apiVersionResponse(requestThrottleMs: Int): ApiVersionsResponse
> = {
> throw new UnsupportedOperationException("This method is not supported in
> SimpleApiVersionManager, use apiVersionResponse(throttleTimeMs,
> finalizedFeatures, epoch) instead")
> } {code}
> but this method is used in SocketServer:
> {code:java}
> private[network] val selector = createSelector(
> ChannelBuilders.serverChannelBuilder(
> listenerName,
> listenerName == config.interBrokerListenerName,
> securityProtocol,
> config,
> credentialProvider.credentialCache,
> credentialProvider.tokenCache,
> time,
> logContext,
> () => apiVersionManager.apiVersionResponse(throttleTimeMs = 0)
> )
> ) {code}
>
> And this method will be invoked in `SaslServerAuthenticator.authenticate` and
> will stop the process.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
