chore: isActive and isConnected early return to avoid issues (#337)

* Early return on isActive and isConnected if init was not called

* Version bump

* Minor issue fix

* coverage fix

Author: CarlosGamero

packages/kafka/lib/AbstractKafkaConsumer.ts

@@ -145,15 +145,31 @@ export abstract class AbstractKafkaConsumer<
    * Returns true if all client's connections are currently connected and the client is connected to at least one broker.
    */
   get isConnected(): boolean {
-    return this.consumer.isConnected()
+    // Streams are created only when init method was called
+    if (!this.consumerStream && !this.messageBatchStream) return false
+    try {
+      return this.consumer.isConnected()
+    } catch (_) {
+      // this should not happen, but if so it means the consumer is not healthy
+      /* v8 ignore next */
+      return false
+    }
   }
 
   /**
    * Returns `true` if the consumer is not closed, and it is currently an active member of a consumer group.
    * This method will return `false` during consumer group rebalancing.
    */
   get isActive(): boolean {
-    return this.consumer.isActive()
+    // Streams are created only when init method was called
+    if (!this.consumerStream && !this.messageBatchStream) return false
+    try {
+      return this.consumer.isActive()
+    } catch (_) {
+      // this should not happen, but if so it means the consumer is not healthy
+      /* v8 ignore next */
+      return false
+    }
   }
 
   async init(): Promise<void> {
@@ -209,9 +225,7 @@ export abstract class AbstractKafkaConsumer<
   async close(): Promise<void> {
     if (!this.consumerStream && !this.messageBatchStream) {
       // Leaving the group in case consumer joined but streams were not created
-      if (this.isActive) {
-        this.consumer.leaveGroup()
-      }
+      if (this.isActive) this.consumer.leaveGroup()
       return
     }
 

packages/kafka/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/kafka",
-    "version": "0.7.0",
+    "version": "0.7.1",
     "engines": {
         "node": ">= 22.14.0"
     },