From 089137ef8dc84955307abddc57bbc8c970cf7f9e Mon Sep 17 00:00:00 2001 From: Francis Cao Date: Thu, 2 Jan 2025 10:31:19 -0800 Subject: [PATCH] update kafka ack setting --- src/lib/kafka.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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, }); }