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)
