diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/AbstractEventPublisher.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/AbstractEventPublisher.java index 9718b8200e1..accfca6104a 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/AbstractEventPublisher.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/AbstractEventPublisher.java @@ -54,6 +54,7 @@ public abstract class AbstractEventPublisher implements EventPublisher { batch.clear(); } catch (RetriableException ex) { setNextBackOff(); + LOG.error("Failed to publish event {} due to {}, will try again in {} ms", changeEvent, ex, currentBackoffTime); Thread.sleep(currentBackoffTime); } catch (Exception e) { LOG.error("Failed to publish event {}", changeEvent);