Log Kafka consumer close errors (#426)

* Log Kafka consumer.close errors

* linting

* Including resolveErrorLog in error report context

Author: kjamrog

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
   }