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)