Merge remote-tracking branch 'origin/dev' into dev

2025-09-08 17:40:29 +00:00 · 2024-04-15 23:43:03 -07:00 · 2024-04-15 23:43:03 -07:00 · 0ef62d004f
commit 0ef62d004f
parent 7c2bb95786 a2e4ab7d46
1 changed files with 2 additions and 7 deletions
--- a/src/lib/kafka.ts
+++ b/src/lib/kafka.ts
@ -17,14 +17,9 @@ function getClient() {
  const ssl: { ssl?: tls.ConnectionOptions | boolean; sasl?: SASLOptions | Mechanism } =
    username && password
      ? {
-          ssl: {
-            checkServerIdentity: () => undefined,
-            ca: [process.env.CA_CERT],
-            key: process.env.CLIENT_KEY,
-            cert: process.env.CLIENT_CERT,
-          },
+          ssl: true,
          sasl: {
-            mechanism: 'plain',
+            mechanism: 'scram-sha-256',
            username,
            password,
          },