Merge remote-tracking branch 'origin/feat/improve_kafka_backpreassure' into feat/improve_kafka_backpreassure

kibertoad · kibertoad · commit 75f6c40ebd60 · 2026-02-28T12:41:07.000+02:00
diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts
@@ -202,7 +202,7 @@ export abstract class AbstractKafkaConsumer<
         })
 
         // Use pipeline for better error handling and backpressure management.
-        // pipeline() internally listens for errors on all streams, so no separate
+        // pipeline() internally listens for errors on all streams
         pipeline(this.consumerStream, this.messageBatchStream).catch((error) =>
           this.handlerError(error),
         )

Original file line number	Diff line number	Diff line change
`@@ -202,7 +202,7 @@ export abstract class AbstractKafkaConsumer<`
`202`	`202`	`})`
`203`	`203`
`204`	`204`	`// Use pipeline for better error handling and backpressure management.`
`205`		`- // pipeline() internally listens for errors on all streams, so no separate`
	`205`	`+ // pipeline() internally listens for errors on all streams`
`206`	`206`	`pipeline(this.consumerStream, this.messageBatchStream).catch((error) =>`
`207`	`207`	`this.handlerError(error),`
`208`	`208`	`)`