[jira] [Created] (KAFKA-15065) ApiVersionRequest is not properly handled in Sasl ControllerServer

["Deng Ziming (Jira)" <ji...@apache.org>]

Deng Ziming created KAFKA-15065:
-----------------------------------

             Summary: ApiVersionRequest is not properly handled in Sasl ControllerServer
                 Key: KAFKA-15065
                 URL: https://issues.apache.org/jira/browse/KAFKA-15065
             Project: Kafka
          Issue Type: Improvement
            Reporter: Deng Ziming


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)