Skip to content

Commit

Permalink
alive
Browse files Browse the repository at this point in the history
  • Loading branch information
pauldambra committed Sep 22, 2023
1 parent 36b59c8 commit 2fe9fd5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion plugin-server/functional_tests/kafka.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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) })
}

0 comments on commit 2fe9fd5

Please sign in to comment.