diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts index 320e704b..14972f7b 100644 --- a/packages/kafka/lib/AbstractKafkaConsumer.ts +++ b/packages/kafka/lib/AbstractKafkaConsumer.ts @@ -3,6 +3,7 @@ import { pipeline } from 'node:stream/promises' import { setTimeout } from 'node:timers/promises' import { InternalError, + isError, resolveGlobalErrorLogObject, stringValueSerializer, type TransactionObservabilityManager, @@ -239,8 +240,14 @@ export abstract class AbstractKafkaConsumer< try { await this.consumer.close() - } catch { - // Ignoring errors at this stage + } catch (err) { + // Reporting error but not throwing further + const resolvedErrorLog = resolveGlobalErrorLogObject(err) + this.logger.warn(resolvedErrorLog, 'Error while closing Kafka consumer') + this.errorReporter.report({ + error: isError(err) ? err : new Error('Unknown error while closing Kafka consumer'), + context: resolvedErrorLog, + }) } this.consumer = undefined }