fixup! first implementation

fluidware-team · Dec 19, 2023 · 8b76974 · 8b76974
1 parent a2ccf3a
commit 8b76974
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/kafka/kafka-consumer.ts b/src/kafka/kafka-consumer.ts
@@ -52,6 +52,7 @@ export class KafkaConsumer implements GenericConsumer {
     if (!this.connected) return;
     try {
       await this.consumer.disconnect();
+      this.connected = false;
     } catch (err) {
       this.logger.error(`Error on disconnect due to: ${err}`);
     }