does that fix the test

PostHog · Mar 22, 2024 · aa694c6 · aa694c6
1 parent 92a3119
commit aa694c6
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/plugin-server/src/utils/db/kafka-producer-wrapper.ts b/plugin-server/src/utils/db/kafka-producer-wrapper.ts
@@ -104,10 +104,8 @@ export class KafkaProducerWrapper {
     }
 
     public async disconnect(): Promise<void> {
-        if (this.producer.isConnected()) {
-            await this.flush()
-            await disconnectProducer(this.producer)
-        }
+        await this.flush()
+        await disconnectProducer(this.producer)
     }
 }