diff --git a/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts b/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts index 0c17580825565..995b2eeae2667 100644 --- a/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts +++ b/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts @@ -24,12 +24,12 @@ describe('CDP Internal Events Consumer', () => { team = await getFirstTeam(hub) processor = new CdpInternalEventsConsumer(hub) - await processor.start() + // Speed hack as we don't need all of kafka to be started for this test + await processor.hogFunctionManager.start(processor['hogTypes']) }) afterEach(async () => { - jest.setTimeout(10000) - await processor.stop() + jest.setTimeout(1000) await closeHub(hub) })