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 index c88f2abe6..ec31683f3 100644 --- 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,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))