From 2744a0f79fc3ecb9bc199ee6edafaf3471f5a7ff Mon Sep 17 00:00:00 2001 From: CarlosGamero Date: Wed, 18 Mar 2026 12:50:47 +0100 Subject: [PATCH 1/3] Dep update --- packages/kafka/package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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", From cb27fb57d73e68717f19bc1c8f61584f9854131c Mon Sep 17 00:00:00 2001 From: CarlosGamero Date: Wed, 18 Mar 2026 12:51:08 +0100 Subject: [PATCH 2/3] Improve error report by including it on context --- packages/kafka/lib/AbstractKafkaService.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 = {}): 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 }, }) } } From 9ce8e80c5ca85a55decac23dedd9257db5d23b37 Mon Sep 17 00:00:00 2001 From: CarlosGamero Date: Wed, 18 Mar 2026 16:08:18 +0100 Subject: [PATCH 3/3] AI comment --- packages/kafka/load-tests/package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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" },