Throw cdc cursor error

airbytehq · Feb 14, 2024 · b4a5acb · b4a5acb
1 parent 16821f0
commit b4a5acb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...src/main/java/io/airbyte/integrations/source/postgres/cdc/PostgresCdcCtidInitializer.java b/...src/main/java/io/airbyte/integrations/source/postgres/cdc/PostgresCdcCtidInitializer.java
@@ -112,6 +112,7 @@ public static List<AutoCloseableIterator<AirbyteMessage>> cdcCtidIteratorsCombin
 
       if (!savedOffsetAfterReplicationSlotLSN) {
         AirbyteTraceMessageUtility.emitAnalyticsTrace(cdcCursorInvalidMessage());
+        AirbyteTraceMessageUtility.emitConfigErrorTrace(new ConfigErrorException("Invalid cdc cursor. Check docs"), "Invalid CDC cursor.");
         LOGGER.warn("Saved offset is before Replication slot's confirmed_flush_lsn, Airbyte will trigger sync from scratch");
       } else if (!isDebugMode(sourceConfig) && PostgresUtils.shouldFlushAfterSync(sourceConfig)) {
         // We do not want to acknowledge the WAL logs in debug mode.