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

abhi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ranger.git


The following commit(s) were added to refs/heads/master by this push:
     new a2f512608 RANGER-5299: Fix AuditHandler with null exception (#645)
a2f512608 is described below

commit a2f512608589d60cda534fbb92f0abbf14c26f93
Author: Alex <[email protected]>
AuthorDate: Sun Aug 31 21:46:05 2025 +0300

    RANGER-5299: Fix AuditHandler with null exception (#645)
---
 .../ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java
 
b/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java
index 17b02d53f..1f1236fc7 100644
--- 
a/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java
+++ 
b/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java
@@ -372,7 +372,9 @@ private Collection<RangerAccessResult> 
callRangerPlugin(List<RangerAccessRequest
 
             return null;
         } finally {
-            auditHandler.flushAudit();
+            if (auditHandler != null) {
+                auditHandler.flushAudit();
+            }
         }
     }
 

Reply via email to