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();
+ }
}
}