Audit: Skip preprocessing if there's nowhere to log (#94)

kafbat · Feb 17, 2024 · a8d111e · a8d111e
1 parent 7b44dd3
commit a8d111e
Showing 1 changed file with 3 additions 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
@@ -207,6 +207,9 @@ 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))