File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2,7 +2,8 @@ import { randomUUID } from 'node:crypto'
22import { pipeline } from 'node:stream/promises'
33import { setTimeout } from 'node:timers/promises'
44import {
5- InternalError , isError ,
5+ InternalError ,
6+ isError ,
67 resolveGlobalErrorLogObject ,
78 stringValueSerializer ,
89 type TransactionObservabilityManager ,
@@ -243,7 +244,7 @@ export abstract class AbstractKafkaConsumer<
243244 // Reporting error but not throwing further
244245 this . logger . warn ( resolveGlobalErrorLogObject ( err ) , 'Error while closing Kafka consumer' )
245246 this . errorReporter . report ( {
246- error : isError ( err ) ? err : new Error ( 'Unknown error while closing Kafka consumer' )
247+ error : isError ( err ) ? err : new Error ( 'Unknown error while closing Kafka consumer' ) ,
247248 } )
248249 }
249250 this . consumer = undefined
You can’t perform that action at this time.
0 commit comments