diff --git a/plugin-server/functional_tests/kafka.ts b/plugin-server/functional_tests/kafka.ts
index 9879f1a01d14e..4c33975ca69ca 100644
--- a/plugin-server/functional_tests/kafka.ts
+++ b/plugin-server/functional_tests/kafka.ts
@@ -38,5 +38,5 @@ export async function createKafkaProducer() {
 
 export async function produce({ topic, message, key }: { topic: string; message: Buffer | null; key: string }) {
     producer = producer ?? (await createKafkaProducer())
-    await defaultProduce({ producer, topic, value: message, key: Buffer.from(key), waitForAck: true })
+    await defaultProduce({ producer, topic, value: message, key: Buffer.from(key) })
 }