diff --git a/README.md b/README.md
index c24cd50d..07c918a1 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,9 @@ Useful utilities, interfaces and base classes for message queue handling.
 
 ## Overview
 
-`message-queue-toolkit ` is an abstraction over several different queue systems, which implements common deserialization, validation and error handling logic. The library provides utilities, interfaces and base classes to build the support for any queue system you may need in your service.
+`message-queue-toolkit ` is an abstraction over several different queue systems, which implements common deserialization,
+validation and error handling logic. The library provides utilities, interfaces and base classes to build the support for
+any queue system you may need in your service.
 
 It consists of the following submodules:
 
diff --git a/packages/kafka/package.json b/packages/kafka/package.json
index 3a7624a1..eda1bc71 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.24.0"
+        "@platformatic/kafka": "^1.26.0"
     },
     "peerDependencies": {
         "@message-queue-toolkit/core": ">=23.0.0",
diff --git a/packages/kafka/test/consumer/PermissionConsumer.ts b/packages/kafka/test/consumer/PermissionConsumer.ts
index aa040e54..b5ef9f4f 100644
--- a/packages/kafka/test/consumer/PermissionConsumer.ts
+++ b/packages/kafka/test/consumer/PermissionConsumer.ts
@@ -75,6 +75,7 @@ export class PermissionConsumer extends AbstractKafkaConsumer<
         handlerSpy: options.handlerSpy ?? true,
         headerRequestIdField: options.headerRequestIdField,
         messageIdField: options.messageIdField,
+        maxWaitTime: 5,
       },
       {
         incrementAmount: 0,
diff --git a/packages/kafka/test/utils/testContext.ts b/packages/kafka/test/utils/testContext.ts
index 44e48c1a..c8576817 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 { adminClient } from '@platformatic/kafka'
+import { Admin } from '@platformatic/kafka'
 import {
   type AwilixContainer,
   asFunction,
@@ -26,7 +26,7 @@ export type TestContext = AwilixContainer<Dependencies>
 type Dependencies = {
   awilixManager: AwilixManager
   kafkaConfig: KafkaConfig
-  kafkaAdmin: adminClient.Admin
+  kafkaAdmin: 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 adminClient.Admin({
+      new Admin({
         clientId: randomUUID(),
         bootstrapBrokers: kafkaConfig.bootstrapBrokers,
       }),
diff --git a/packages/kafka/vitest.config.ts b/packages/kafka/vitest.config.ts
index 10d14e3c..00c6ebbb 100644
--- a/packages/kafka/vitest.config.ts
+++ b/packages/kafka/vitest.config.ts
@@ -16,7 +16,7 @@ export default defineConfig({
         lines: 93,
         functions: 91,
         branches: 85,
-        statements: 93,
+        statements: 92,
       },
     },
   },