You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Deng Ziming (Jira)" <ji...@apache.org> on 2023/06/07 08:23:00 UTC
[jira] [Updated] (KAFKA-15065) ApiVersionRequest is not properly handled in Sasl ControllerServer
[ 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)