diff --git a/__tests__/workers/cdc/primary.ts b/__tests__/workers/cdc/primary.ts
index 6f57377b53..c4af488c2f 100644
--- a/__tests__/workers/cdc/primary.ts
+++ b/__tests__/workers/cdc/primary.ts
@@ -6917,10 +6917,10 @@ describe('organization', () => {
 
     expect(triggerTypedEvent).toHaveBeenCalledTimes(2);
     expect(jest.mocked(triggerTypedEvent).mock.calls[0][1]).toEqual(
-      'api.v1.opportunity-updated',
+      'api.v1.opportunity-added',
     );
     expect(jest.mocked(triggerTypedEvent).mock.calls[1][1]).toEqual(
-      'api.v1.opportunity-updated',
+      'api.v1.opportunity-added',
     );
   });
 
diff --git a/src/common/opportunity/pubsub.ts b/src/common/opportunity/pubsub.ts
index 9c35e8cbd4..11e522761d 100644
--- a/src/common/opportunity/pubsub.ts
+++ b/src/common/opportunity/pubsub.ts
@@ -334,12 +334,10 @@ export const notifyJobOpportunity = async ({
   con,
   logger,
   opportunityId,
-  isUpdate = false,
 }: {
   con: DataSource;
   logger: FastifyBaseLogger;
   opportunityId: string;
-  isUpdate?: boolean;
 }) => {
   const [opportunity, organization, keywords, users, locations] =
     await queryReadReplica(con, async ({ queryRunner }) => {
@@ -458,11 +456,8 @@ export const notifyJobOpportunity = async ({
     excludedUserIds,
   });
 
-  const topicName = isUpdate
-    ? 'api.v1.opportunity-updated'
-    : 'api.v1.opportunity-added';
   try {
-    await triggerTypedEvent(logger, topicName, message);
+    await triggerTypedEvent(logger, 'api.v1.opportunity-added', message);
   } catch (_err) {
     const err = _err as Error;
     logger.error({ err, message }, 'failed to send opportunity event');
diff --git a/src/workers/cdc/primary.ts b/src/workers/cdc/primary.ts
index 6af10c9041..8745f6705a 100644
--- a/src/workers/cdc/primary.ts
+++ b/src/workers/cdc/primary.ts
@@ -1388,7 +1388,6 @@ const onOpportunityChange = async (
       con,
       logger,
       opportunityId: data.payload.after!.id,
-      isUpdate: true,
     });
     if (data.payload.after?.state !== OpportunityState.LIVE) {
       await con
@@ -1447,7 +1446,6 @@ const onOrganizationChange = async (
           con,
           logger,
           opportunityId: opportunity.id,
-          isUpdate: true,
         });
       }),
     );