From 534733b1af08ec63e774a45081c167f2e557f757 Mon Sep 17 00:00:00 2001
From: Krzysztof Jamrog <krzysztof.jamrog@lokalise.com>
Date: Tue, 3 Feb 2026 14:00:03 +0100
Subject: [PATCH] platformatic/kafka version update + tests fix

---
 packages/kafka/lib/AbstractKafkaConsumer.ts | 2 +-
 packages/kafka/package.json                 | 2 +-
 packages/kafka/test/utils/testContext.ts    | 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts
index cc69a009..c632669a 100644
--- a/packages/kafka/lib/AbstractKafkaConsumer.ts
+++ b/packages/kafka/lib/AbstractKafkaConsumer.ts
@@ -129,7 +129,7 @@ export abstract class AbstractKafkaConsumer<
     this.consumer.on('consumer:group:join', (_) =>
       this.logger.debug(logDetails, 'Consumer is joining a group'),
     )
-    this.consumer.on('consumer:rejoin', (_) =>
+    this.consumer.on('consumer:group:rejoin', () =>
       this.logger.debug(logDetails, 'Consumer is re-joining a group after a rebalance'),
     )
     this.consumer.on('consumer:group:leave', (_) =>
diff --git a/packages/kafka/package.json b/packages/kafka/package.json
index 64df6fb3..bc47b7d2 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.23.0"
+        "@platformatic/kafka": "^1.24.0"
     },
     "peerDependencies": {
         "@message-queue-toolkit/core": ">=23.0.0",
diff --git a/packages/kafka/test/utils/testContext.ts b/packages/kafka/test/utils/testContext.ts
index c8576817..44e48c1a 100644
--- a/packages/kafka/test/utils/testContext.ts
+++ b/packages/kafka/test/utils/testContext.ts
@@ -6,7 +6,7 @@ import {
   type TransactionObservabilityManager,
 } from '@lokalise/node-core'
 import type { MessageMetricsManager } from '@message-queue-toolkit/core'
-import { Admin } from '@platformatic/kafka'
+import { adminClient } from '@platformatic/kafka'
 import {
   type AwilixContainer,
   asFunction,
@@ -26,7 +26,7 @@ export type TestContext = AwilixContainer<Dependencies>
 type Dependencies = {
   awilixManager: AwilixManager
   kafkaConfig: KafkaConfig
-  kafkaAdmin: Admin
+  kafkaAdmin: adminClient.Admin
   errorReporter: ErrorReporter
   logger: CommonLogger
   transactionObservabilityManager: TransactionObservabilityManager
@@ -60,7 +60,7 @@ const resolveDIConfig = (awilixManager: AwilixManager): DiConfig => ({
   kafkaConfig: asFunction(getKafkaConfig, SINGLETON_CONFIG),
   kafkaAdmin: asFunction(
     ({ kafkaConfig }) =>
-      new Admin({
+      new adminClient.Admin({
         clientId: randomUUID(),
         bootstrapBrokers: kafkaConfig.bootstrapBrokers,
       }),