test fix

CarlosGamero · CarlosGamero · commit a14d4b3a661f · 2026-03-19T17:13:10.000+01:00
diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts
@@ -200,7 +200,6 @@ 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,7 +200,6 @@ 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`
`204`	`203`	`throw new InternalError({`
`205`	`204`	`message: 'Consumer init failed',`
`206`	`205`	`errorCode: 'KAFKA_CONSUMER_INIT_ERROR',`