diff --git a/src/lib/kafka.ts b/src/lib/kafka.ts index 99fc323ac..687825cab 100644 --- a/src/lib/kafka.ts +++ b/src/lib/kafka.ts @@ -71,7 +71,7 @@ async function sendMessage( value: JSON.stringify(message), }, ], - acks: -1, + acks: 1, }); }