Merge branch 'dev' into analytics

2025-02-14 21:10:34 +01:00 · 2024-04-15 15:01:19 -07:00 · 2024-04-15 15:01:19 -07:00 · 8451e3261d
commit 8451e3261d
parent 5aff8d1836 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,
          },