Fix passing instance method as param (#361)

kibertoad · web-flow · commit 220e46104d85 · 2025-11-21T20:59:56.000+02:00
diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts
@@ -216,7 +216,7 @@ export abstract class AbstractKafkaConsumer<
 
       // we are not waiting for the stream to complete
       // because init() must return promised void
-      this.handleSyncStream(stream).catch(this.handlerError)
+      this.handleSyncStream(stream).catch((error) => this.handlerError(error))
     }
 
     this.consumerStream.on('error', (error) => this.handlerError(error))

Original file line number	Diff line number	Diff line change
`@@ -216,7 +216,7 @@ export abstract class AbstractKafkaConsumer<`
`216`	`216`
`217`	`217`	`// we are not waiting for the stream to complete`
`218`	`218`	`// because init() must return promised void`
`219`		`- this.handleSyncStream(stream).catch(this.handlerError)`
	`219`	`+ this.handleSyncStream(stream).catch((error) => this.handlerError(error))`
`220`	`220`	`}`
`221`	`221`
`222`	`222`	`this.consumerStream.on('error', (error) => this.handlerError(error))`