diff --git a/packages/kafka/lib/AbstractKafkaService.ts b/packages/kafka/lib/AbstractKafkaService.ts
index aa0d9275..bfaf3164 100644
--- 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
index 80d2a323..a5993325 100644
--- 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
index 5609b4d5..711a7c6c 100644
--- 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",