[kafka] branch trunk updated: MINOR: Add a log to print acl change notification details

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

manikumar pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new f0ef578  MINOR: Add a log to print acl change notification details
f0ef578 is described below

commit f0ef5785e3964eab3844a36dc95c4c33fcf98ef5
Author: Manikumar Reddy <ma...@gmail.com>
AuthorDate: Thu Jan 7 16:32:22 2021 +0530

    MINOR: Add a log to print acl change notification details
    
    This is similar to config change logs for topic/broker. This will be useful for debugging any acl related issues.
    
    Author: Manikumar Reddy <ma...@gmail.com>
    
    Reviewers: Rajini Sivaram <ra...@googlemail.com>
    
    Closes #9841 from omkreddy/acl-change-log
---
 core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala b/core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
index 475baef..46c33ca 100644
--- a/core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
+++ b/core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala
@@ -729,6 +729,7 @@ class AclAuthorizer extends Authorizer with Logging {
   private[authorizer] def processAclChangeNotification(resource: ResourcePattern): Unit = {
     lock synchronized {
       val versionedAcls = getAclsFromZk(resource)
+      info(s"Processing Acl change notification for $resource, versionedAcls : ${versionedAcls.acls}, zkVersion : ${versionedAcls.zkVersion}")
       updateCache(resource, versionedAcls)
     }
   }