[
https://issues.apache.org/jira/browse/KAFKA-20651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ibenchhida updated KAFKA-20651:
-------------------------------
Issue Type: Improvement (was: Bug)
> StandardAuthorizer: cache KafkaPrincipal in StandardAcl to eliminate
> allocation hotspot
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-20651
> URL: https://issues.apache.org/jira/browse/KAFKA-20651
> Project: Kafka
> Issue Type: Improvement
> Components: core
> Affects Versions: 3.9.2
> Environment: KRaft-based clusters using StandardAuthorizer (3.7.x,
> 3.8.x, 3.9.x, 4.0.x — all versions with the current checkSection
> implementation)
> Reporter: ibenchhida
> Priority: Critical
>
> In KRaft mode, StandardAuthorizerData.findResult() calls acl.kafkaPrincipal()
> for every ACL visited during authorization. Despite being called repeatedly
> for the same principal strings (e.g., "User:alice"), kafkaPrincipal() parses
> the principal string from scratch on each invocation:
> public KafkaPrincipal kafkaPrincipal() {
> int colonIndex = principal.indexOf(":");
> String principalType = principal.substring(0, colonIndex); // alloc 1
> String principalName = principal.substring(colonIndex + 1); // alloc 2
> return new KafkaPrincipal(principalType, principalName); // alloc
> 3
> }
> With a large number of ACLs and repeated authorization requests, this
> generates millions of transient String + KafkaPrincipal allocations,
> creating unnecessary CPU and GC pressure.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
