update kafka ack setting

2025-01-02 10:31:19 -08:00
parent be3b5b88f0
commit 089137ef8d
1 changed files with 1 additions and 1 deletions
--- 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,
  });
 }