Fixes

PostHog · Sep 5, 2024 · c5682e8 · c5682e8
1 parent 37c6c2d
commit c5682e8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugin-server/tests/cdp/helpers/kafka-observer.ts b/plugin-server/tests/cdp/helpers/kafka-observer.ts
@@ -24,6 +24,7 @@ export const createKafkaObserver = async (hub: Hub, topics: string[]): Promise<T
 
     const adminClient = createAdminClient(createRdConnectionConfigFromEnvVars(hub))
     await Promise.all(topics.map((topic) => ensureTopicExists(adminClient, topic, 1000)))
+    adminClient.disconnect()
 
     consumer.connect()
     consumer.subscribe(topics)