Improve kafka error report (#418)

CarlosGamero · web-flow · commit ce72b588f740 · 2026-03-18T16:15:51.000+01:00
* Dep update

* Improve error report by including it on context

* AI comment
diff --git a/packages/kafka/lib/AbstractKafkaService.ts b/packages/kafka/lib/AbstractKafkaService.ts
@@ -126,11 +126,12 @@ export abstract class AbstractKafkaService<
   }
 
   protected handlerError(error: unknown, context: Record<string, unknown> = {}): void {
-    this.logger.error({ ...resolveGlobalErrorLogObject(error), ...context })
+    const resolvedErrorLog = resolveGlobalErrorLogObject(error)
+    this.logger.error({ ...resolvedErrorLog, ...context })
     if (isError(error))
       this.errorReporter.report({
         error,
-        context: context,
+        context: { ...context, error: resolvedErrorLog.error },
       })
   }
 }
diff --git a/packages/kafka/load-tests/package.json b/packages/kafka/load-tests/package.json
@@ -33,7 +33,7 @@
         "@message-queue-toolkit/schemas": "file:../../schemas",
         "@lokalise/node-core": "^14.2.0",
         "@platformatic/dynamic-buffer": "^0.3.1",
-        "@platformatic/kafka": "1.28.0",
+        "@platformatic/kafka": "1.30.0",
         "pg": "^8.19.0",
         "zod": "^4.0.17"
     },
diff --git a/packages/kafka/package.json b/packages/kafka/package.json
@@ -53,7 +53,7 @@
     "dependencies": {
         "@lokalise/node-core": "^14.2.0",
         "@lokalise/universal-ts-utils": "^4.5.1",
-        "@platformatic/kafka": "^1.29.0"
+        "@platformatic/kafka": "^1.30.0"
     },
     "peerDependencies": {
         "@message-queue-toolkit/core": ">=23.0.0",

Original file line number	Diff line number	Diff line change
`@@ -126,11 +126,12 @@ export abstract class AbstractKafkaService<`
`126`	`126`	`}`
`127`	`127`
`128`	`128`	`protected handlerError(error: unknown, context: Record<string, unknown> = {}): void {`
`129`		`- this.logger.error({ ...resolveGlobalErrorLogObject(error), ...context })`
	`129`	`+ const resolvedErrorLog = resolveGlobalErrorLogObject(error)`
	`130`	`+ this.logger.error({ ...resolvedErrorLog, ...context })`
`130`	`131`	`if (isError(error))`
`131`	`132`	`this.errorReporter.report({`
`132`	`133`	`error,`
`133`		`- context: context,`
	`134`	`+ context: { ...context, error: resolvedErrorLog.error },`
`134`	`135`	`})`
`135`	`136`	`}`
`136`	`137`	`}`