This is an automated email from the ASF dual-hosted git repository. abhi pushed a commit to branch ranger-2.8 in repository https://gitbox.apache.org/repos/asf/ranger.git
commit ef3ae513174a7bed04acc8f84ed0903959c4210c Author: Alex <[email protected]> AuthorDate: Sun Aug 31 11:55:13 2025 -0700 RANGER-5299: Fix AuditHandler with null exception --- .../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 96a36abe9..a66141d7a 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 @@ -300,7 +300,9 @@ private Collection<RangerAccessResult> callRangerPlugin(List<RangerAccessRequest logger.error("Error while calling isAccessAllowed(). requests={}", rangerRequests, t); return null; } finally { - auditHandler.flushAudit(); + if (auditHandler != null) { + auditHandler.flushAudit(); + } } }
