diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/engine/IncrementalIngestionEngine.ts b/plugins/catalog-backend-module-incremental-ingestion/src/engine/IncrementalIngestionEngine.ts index e4d11b5f0d..311af0f6de 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/src/engine/IncrementalIngestionEngine.ts +++ b/plugins/catalog-backend-module-incremental-ingestion/src/engine/IncrementalIngestionEngine.ts @@ -41,7 +41,7 @@ export class IncrementalIngestionEngine { minutes: 30 }, { hours: 3 }, ]; - this.providerEventTopic = `${options.provider.getProviderName()}-delta`; + this.providerEventTopic = `${options.provider.getProviderName()}-push`; } async taskFn(signal: AbortSignal) {