[improve] [broker] Print warn log if compaction failure
@@ -3031,6 +3031,11 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
} else {
currentCompaction = brokerService.pulsar().getCompactor().compact(topic);
}
+ currentCompaction.whenComplete((ignore, ex) -> {
+ if (ex != null){
+ log.warn("[{}] Compaction failure.", topic, ex);
+ }
+ });
} else {
throw new AlreadyRunningException("Compaction already in progress");
}
