diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java index 51b3630781..f6312fad04 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java @@ -61,6 +61,11 @@ public AuditTableDataRouter(ISymmetricEngine engine) { public Set routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, Set nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter) { + + if (initialLoad) { // loads are not audited; this is for CDC. + return null; + } + DataEventType eventType = dataMetaData.getData().getDataEventType(); if (eventType == DataEventType.INSERT || eventType == DataEventType.UPDATE || eventType == DataEventType.DELETE) {