AI comment

CarlosGamero · CarlosGamero · commit 8659a3ef85d7 · 2026-03-19T16:35:19.000+01:00
diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts
@@ -200,6 +200,7 @@ export abstract class AbstractKafkaConsumer<
         this.consumerStream.on('error', (error) => this.handleError(error))
       }
     } catch (error) {
+      await this.close() // clean-up
       throw new InternalError({
         message: 'Consumer init failed',
         errorCode: 'KAFKA_CONSUMER_INIT_ERROR',

Original file line number	Diff line number	Diff line change
`@@ -200,6 +200,7 @@ export abstract class AbstractKafkaConsumer<`
`200`	`200`	`this.consumerStream.on('error', (error) => this.handleError(error))`
`201`	`201`	`}`
`202`	`202`	`} catch (error) {`
	`203`	`+ await this.close() // clean-up`
`203`	`204`	`throw new InternalError({`
`204`	`205`	`message: 'Consumer init failed',`
`205`	`206`	`errorCode: 'KAFKA_CONSUMER_INIT_ERROR',`