Chhida opened a new pull request, #22482:
URL: https://github.com/apache/kafka/pull/22482

   Use ConcurrentHashMap to cache parsed KafkaPrincipal objects per unique 
principal string, reducing allocation overhead from repeated 
substring/constructor calls during ACL authorization.
   
   Reviewers: TBD
   
   Delete this text and replace it with a detailed description of your change. 
The 
   PR title and body will become the squashed commit message.
   
   If you would like to tag individuals, add some commentary, upload images, or
   include other supplemental information that should not be part of the 
eventual
   commit message, please use a separate comment.
   
   If applicable, please include a summary of the testing strategy (including 
   rationale) for the proposed change. Unit and/or integration tests are 
expected
   for any behavior change and system tests should be considered for larger
   changes.
   
   `(data-plane-kafka-request-handler-0" #80 daemon prio=5 os_prio=0 
cpu=17207014.77ms elapsed=18143.19s tid=0x00007f76d50aa800 nid=0x8e7bb runnable 
[0x00007f7681480000]
   
     java.lang.Thread.State: RUNNABLE
   
          at 
org.apache.kafka.metadata.authorizer.StandardAcl.kafkaPrincipal(StandardAcl.java:106)
   
          at 
org.apache.kafka.metadata.authorizer.StandardAuthorizerData.findResult(StandardAuthorizerData.java:493)
   
          at 
org.apache.kafka.metadata.authorizer.StandardAuthorizerData.checkSection(StandardAuthorizerData.java:428)
   
          at 
org.apache.kafka.metadata.authorizer.StandardAuthorizerData.findAclRule(StandardAuthorizerData.java:367)
   
          at 
org.apache.kafka.metadata.authorizer.StandardAuthorizerData.authorize(StandardAuthorizerData.java:247)
   
          at 
org.apache.kafka.metadata.authorizer.StandardAuthorizer.authorize(StandardAuthorizer.java:143)
   
          at kafka.server.AuthHelper.filterByAuthorized(AuthHelper.scala:113)
   
          at 
kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:1350)
   
          at kafka.server.KafkaApis.handle(KafkaApis.scala:192)
   
          at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:159)
   
          at java.lang.Thread.run([email protected]/Thread.java:829)
   
   )`


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to