Kafka manual group join (#311)

* Adding manual group join

* Release prepare + lint fix

Author: CarlosGamero

packages/kafka/lib/AbstractKafkaConsumer.ts

@@ -112,6 +112,13 @@ export abstract class AbstractKafkaConsumer<
 
     try {
       const { handlers, ...consumeOptions } = this.options // Handlers cannot be passed to consume method
+
+      // https://github.com/platformatic/kafka/blob/main/docs/consumer.md#my-consumer-is-not-receiving-any-message-when-the-application-restarts
+      await this.consumer.joinGroup({
+        sessionTimeout: consumeOptions.sessionTimeout,
+        rebalanceTimeout: consumeOptions.rebalanceTimeout,
+        heartbeatInterval: consumeOptions.heartbeatInterval,
+      })
       this.consumerStream = await this.consumer.consume({ ...consumeOptions, topics })
     } catch (error) {
       throw new InternalError({

packages/kafka/package.json

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