Skip auditing preprocessing if there's nowhere to log

kafbat · Feb 1, 2024 · ed9e2bd · ed9e2bd
1 parent c75c5cc
commit ed9e2bd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/api/src/main/java/io/kafbat/ui/service/audit/AuditService.java b/api/src/main/java/io/kafbat/ui/service/audit/AuditService.java
@@ -180,6 +180,7 @@ public boolean isAuditTopic(KafkaCluster cluster, String topic) {
   }
 
   public void audit(AccessContext acxt, Signal<?> sig) {
+    if (auditWriters.isEmpty()) return;
     if (sig.isOnComplete()) {
       extractUser(sig)
           .doOnNext(u -> sendAuditRecord(acxt, u))