Fix

plugin-server/functional_tests/kafka.ts

@@ -3,7 +3,7 @@ import SnappyCodec from 'kafkajs-snappy'
 import { HighLevelProducer } from 'node-rdkafka'
 
 import { defaultConfig } from '../src/config/config'
-import { produce as defaultProduce } from '../src/kafka/producer'
+import { KafkaProducerWrapper } from '../src/kafka/producer'
 
 CompressionCodecs[CompressionTypes.Snappy] = SnappyCodec
 
@@ -48,5 +48,6 @@ export async function produce({
     waitForAck: boolean
 }) {
     producer = producer ?? (await createKafkaProducer())
-    await defaultProduce({ producer, topic, value: message, key: Buffer.from(key), waitForAck })
+
+    await new KafkaProducerWrapper(producer).produce({ topic, value: message, key: Buffer.from(key), waitForAck })
 }