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,
       }),