diff --git a/plugin-server/functional_tests/api.ts b/plugin-server/functional_tests/api.ts
index 6d16cdb41a498..89b1f7cd10698 100644
--- a/plugin-server/functional_tests/api.ts
+++ b/plugin-server/functional_tests/api.ts
@@ -5,6 +5,7 @@ import parsePrometheusTextFormat from 'parse-prometheus-text-format'
 import { PoolClient } from 'pg'
 
 import { defaultConfig } from '../src/config/config'
+import { KAFKA_SESSION_RECORDING_SNAPSHOT_ITEM_EVENTS } from '../src/config/kafka-topics'
 import {
     ActionStep,
     Hook,
@@ -62,7 +63,7 @@ export const capture = async ({
     $set = undefined,
     $set_once = undefined,
     topic = ['$performance_event', '$snapshot_items'].includes(event)
-        ? 'session_recording_events'
+        ? KAFKA_SESSION_RECORDING_SNAPSHOT_ITEM_EVENTS
         : 'events_plugin_ingestion',
 }: {
     teamId: number | null
diff --git a/plugin-server/functional_tests/session-recordings.test.ts b/plugin-server/functional_tests/session-recordings.test.ts
index 78a8e4f1a9d57..b8063f896f59c 100644
--- a/plugin-server/functional_tests/session-recordings.test.ts
+++ b/plugin-server/functional_tests/session-recordings.test.ts
@@ -34,7 +34,7 @@ test.concurrent(
         })
 
         const events = await waitForExpect(async () => {
-            const events = await fetchSessionReplayEvents(teamId)
+            const events = await fetchSessionReplayEvents(teamId, sessionId)
             expect(events.length).toBe(1)
             return events
         })